我收到以下错误:
java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access
当我将此包含在代码中时:
CuratorFrameworkFactory.newClient()
我不明白是什么导致了这个错误。有什么帮助吗?
谢谢。
我收到以下错误:
java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access
当我将此包含在代码中时:
CuratorFrameworkFactory.newClient()
我不明白是什么导致了这个错误。有什么帮助吗?
谢谢。
1条答案
按热度按时间epggiuax1#
Kafka明确提到:
Kafka消费者不是线程安全的。所有网络i/o都发生在发出调用的应用程序的线程中。用户有责任确保多线程访问正确同步。不同步的访问将导致concurrentmodificationexception。
更多详情请参见http://kafka.apache.org/21/javadoc/org/apache/kafka/clients/consumer/kafkaconsumer.html#multithreaded