Kafka consumer with filters java shastra