Question:I am running on
spring-kafka:2.6.7and I am looking for a way to set a custom task executor for my listener. Below is my Kafka configuration.
factory.getContainerProperties().setConsumerTaskExecutor()but not sure how to set task executor for listener.
Answer:2.6.x is out of OSS support https://spring.io/projects/spring-kafka#support
The same thread used to poll the consumer is used to call the listener.
In very early versions (before 1.3), there were two threads due to limitations in the kafka-clients, but there is only one now (for the last 5 years).
If you have better answer, please add a comment about this, thank you!