source: class KafkaMRecordSourceTest implements MRecordSource {
  
      private transient KafkaMRecordSource source;
      private transient KafkaConsumer<String, UntypedValues> consumer;
  
      @Test
      public void init() {
  
target:         try{
              source.init();
          } catch (Exception ex){
              fail("failed to init");
          }
      }
  
  }