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