Получение KafkaConsumer не является безопасным для ошибки многопоточного доступа, когда я использую CuratorFrameworkFactory.newClient ()

Question

Я получаю эту ошибку ниже:

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

, когда я включаю это в свой код:

CuratorFrameworkFactory.newClient()

Я не понимаю, что является причиной ошибки.Любая помощь?

Спасибо.

Answer 1

Kafka Javdocs четко упоминает, что:

Потребитель Kafka НЕ является потокобезопасным.Весь сетевой ввод / вывод происходит в потоке приложения, выполняющего вызов.Пользователь несет ответственность за обеспечение правильной синхронизации многопоточного доступа.Несинхронизированный доступ приведет к исключению ConcurrentModificationException.

Более подробная информация представлена ​​на http://kafka.apache.org/21/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#multithreaded