why does kafka concurrentmessagelistenercontainer work as a batch function?

Just change your listener to implement BatchMessageListener or one of its sub-interfaces instead. The container will automatically detect its type.

See Message Listeners.

The @KafkaListener code uses the factory flag to determine which type of listener adapter to create.

CLICK HERE to find out more related problems solutions.

Leave a Comment

Your email address will not be published.

Scroll to Top