I am batch processing messages using kafka listener and I want them to be validated before processing. Here’s how I have configured my kafka listener