We want to create amazing apps without being stopped by crashes. Join us to help others who have the same bug.

I want to fix my crash

I want to help others

java.util.ConcurrentModificationException: KafkaConsumer is not safe for
multi-threaded access
at
org.apache.kafka.clients.consumer.KafkaConsumer.acquire(KafkaConsumer.java:1282)
at
org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1213)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.close(WorkerSinkTask.java:128)

java.util.ConcurrentModificationException: KafkaConsumer is not safe for
multi-threaded access
at
org.apache.kafka.clients.consumer.KafkaConsumer.acquire(KafkaConsumer.java:1282)
at
org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1213)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.close(WorkerSinkTask.java:128)

Root Cause Analysis

java.util.ConcurrentModificationException

KafkaConsumer is not safe for
multi-threaded access
at
org.apache.kafka.clients.consumer.KafkaConsumer.acquire(KafkaConsumer.java:1282)
at
org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1213)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.close(WorkerSinkTask.java:128)