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

uqjltbpv 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(431)

我收到以下错误：

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

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

CuratorFrameworkFactory.newClient()

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

Java apache-kafka multithreading apache-curator

来源：https://stackoverflow.com/questions/53847066/getting-kafkaconsumer-is-not-safe-for-multi-threaded-access-error-when-i-use-cur

1条答案

按热度按时间

epggiuax1#

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

赞(0）回复(0）举报 2021-06-07

我来回答

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

1条答案

相关问题

热门标签

最新问答