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)

search-hadoop.com | 5 months ago
  1. 0

    Kafka, mail # user - Re: Kafka Connect tasks consumers issue - 2016-05-11, 09:41

    search-hadoop.com | 5 months ago
    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)
  2. 0

    HDFS Connector consumed 400K+ messages before throwing CommitFailedException - no output file!

    Google Groups | 1 year ago | Uday Menon
    java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access
  3. 0

    [Hadoop Worker] KafkaConsumer is not safe for multi-threaded access

    GitHub | 2 weeks ago | thanhtien522
    java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Intermittent failure of Kafka integration tests

    GitHub | 10 months ago | jamesnetherton
    java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access
  6. 0

    Clarification on Kafka Connect running in distributed mode - Production

    Google Groups | 5 months ago | Saravanan Tirugnanum
    java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. 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)

      at org.apache.kafka.connect.runtime.Worker.stopTask()
    2. org.apache.kafka
      Worker.stopTask
      1. org.apache.kafka.connect.runtime.Worker.stopTask(Worker.java:313)
      1 frame