public void testEventsInjectedIntoKafkaWithoutFilter() throws Exception {
  Map<String,String> srcProps=makeSourceProps(Utils.join(TOPICS,","));
  srcProps.remove(IgniteSourceConstants.CACHE_FILTER_CLASS);
  doTest(srcProps,false);
}

public void testEventsInjectedIntoKafkaWithoutFilter ( ) throws Exception { Map < String , String > srcProps = makeSourceProps ( Utils . join ( TOPICS , "," ) ) ; srcProps . remove ( IgniteSourceConstants . CACHE_FILTER_CLASS ) ; doTest ( srcProps , false ) ; }
tests data flow from injecting data into grid and transferring it to kafka cluster without user - specified filter .
