我收到以下错误:
java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access
当我将其包含在我的代码中时:
CuratorFrameworkFactory.newClient()
我不明白是什么导致了错误。有帮助吗？
谢谢。
最佳答案
Kafka Javdocs 明确提到:
Kafka 消费者不是线程安全的。所有网络 I/O 都发生在进行调用的应用程序的线程中。确保多线程访问正确同步是用户的责任。不同步的访问将导致 ConcurrentModificationException。
关于java - 当我使用 CuratorFrameworkFactory.newClient() 时，获取 KafkaConsumer 对于多线程访问错误是不安全的，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/53847066/