多线程消费 KafkaConsumer is not safe for multi-threaded access 修订版本明细

源

采纳

编辑于

√锋²º¹8ヾ/❤

多线程消费 KafkaConsumer is not safe for multi-threaded access

kafka

一个副本、一个分区生产信息。

消费的时候，开启了3个线程，并发消费同一主题，同一个组。

启动后瞬间就出现：

Exception in thread "Thread-10" java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access
at org.apache.kafka.clients.consumer.KafkaConsumer.acquire(KafkaConsumer.java:1674)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1031)
at com.oristartech.kafka.core.consumer.ConsumerHandler$1.run(ConsumerHandler.java:100)
at java.lang.Thread.run(Thread.java:748)

翻看了一下其他问题发问，好像是说消费者是非线程安全的，而且线程和分区也有着限定的关系（线程 ≤ 分区）。

如果要满足多线程消费同主题+同分组，该如何处理才好

预览