Kafka 1.0 и весенняя загрузка - координатор выбрал неверный протокол назначения: ноль - PullRequest
0 голосов
/ 01 июня 2018

У нас есть клиент Kafka 1.0 с spring-kafka (версия 1.1.1.RELEASE), потому что наша среда Spring - это 4.3.3.RELEASE, но исключая из этого kafka 0.10.0.1.Брокер представляет собой кластер из 3 узлов с включенной версией kafka 1.0 и совместимостью тем

Иногда в журнал записывается следующее исключение до заполнения диска

Исключение контейнера

java.lang.IllegalStateException: координатор выбрал недопустимый протокол назначения: пусто в org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete (ConsumerCoordinator.java:217) ~ [kafka-clients-1.0.0.jar!:?] at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded (AbstractCoordinator.java:367) ~ [kafka-clients-1.0.0.jar! / :?] в org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup (AbstractCoordinator.java:316) ~ [kafka-clients-1.0.0.jar! / :?] at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll (ConsumerCoordinator.java: 295) ~ [kafka-clients-1.0.0.jar! / :?] at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce (KafkaConsumer.java:1138) ~ [kafka-clients-1.0.0.jar! / :?] вorg.apache.kafka.clients.consumer.KafkaConsumer.poll (KafkaConsumer.java:1103) ~ [kafka-clients-1.0.0.jar! / :?] в org.springframework.kafka.listener.KafkaMessageListenerContainer $ прослушиватель(KafkaMessageListenerContainer.java:532) [spring-kafka-1.1.1.RELEASE.jar! / :?] at java.util.concurrent.Executors $ RunnableAdapter.call (Executors.java:511) [?: 1.8.0_161]в java.util.concurrent.FutureTask.run (FutureTask.java:266) [?: 1.8.0_161] в java.lang.Thread.run (Thread.java:748) [?: 1.8.0_161]

Знаете ли вы, почему эта печать журнала?Каковы причины этой ошибки?Или как это предотвратить?

Назначение раздела по умолчанию, Диапазон.Это не происходит с самого начала службы.После нескольких часов или дней обслуживания

Мы думаем, что узел приложения, являющийся потребителем, выполняет fullgc, обнаруживается и пытается перейти на другой узел приложения, но не может и начинает писать это ..... но мы не знаем, является ли это причиной или следствием.

Спасибо !!

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...