当我使用curatorframeworkfactory.newclient()时,获取kafkaconsumer对于多线程访问错误是不安全的

uqjltbpv  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(418)

我收到以下错误:

java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access

当我将此包含在代码中时:

CuratorFrameworkFactory.newClient()

我不明白是什么导致了这个错误。有什么帮助吗?
谢谢。

epggiuax

epggiuax1#

Kafka明确提到:
Kafka消费者不是线程安全的。所有网络i/o都发生在发出调用的应用程序的线程中。用户有责任确保多线程访问正确同步。不同步的访问将导致concurrentmodificationexception。
更多详情请参见http://kafka.apache.org/21/javadoc/org/apache/kafka/clients/consumer/kafkaconsumer.html#multithreaded

相关问题