I have a spring cloud function that reads from kafka topic. Here's how I define the consumer as it