Integrated ANTLR based filter with Kafka Subscription