spring-kafka icon indicating copy to clipboard operation
spring-kafka copied to clipboard

Kafkaconsumer is not safe for multi-threading access

Open ayush11-96 opened this issue 11 months ago • 3 comments
trafficstars

In what version(s) of Spring for Apache Kafka are you seeing this issue?

For example:

2.8.5

Describe the bug

Caused by: java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access at org.apache.kafka.clients.consumer.KafkaConsumer.acquire(KafkaConsumer.java:2464) at org.apache.kafka.clients.consumer.KafkaConsumer.acquireAndEnsureOpen(KafkaConsumer.java:2448) at org.apache.kafka.clients.consumer.KafkaConsumer.subscribe(KafkaConsumer.java:950) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.subscribeOrAssignTopics(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.(KafkaMessageListenerContainer.java:784) at org.springframework.kafka.listener.KafkaMessageListenerContainer.doStart(KafkaMessageListenerContainer.java:350) at org.springframework.kafka.listener.AbstractMessageListenerContainer.start(AbstractMessageListenerContainer.java:466) at org.springframework.kafka.listener.ConcurrentMessageListenerContainer.doStart(ConcurrentMessageListenerContainer.java:209) at org.springframework.kafka.listener.AbstractMessageListenerContainer.start(AbstractMessageListenerContainer.java:466)

To Reproduce During app startup

ayush11-96 avatar Dec 01 '24 05:12 ayush11-96