Я пришел, чтобы найти ответ на свой вопрос при использовании kafka.
Я использую kafka version 2.1.0 и kafka соединяются вместе.
Пока я использовал,
[2019-02-24 13: 23: 17,056] ИНФОРМАЦИЯ [GroupMetadataManager brokerId = 2] Имя темы группы перешло в Dead в поколении 12 (kafka.coordinator.group.GroupMetadataManager)
TheВышеуказанная ошибка произошла на брокере kafka, и после этого время истекает как у производителя, так и у потребителя, потому что брокер не примет запрос.
Он не отключится с помощью kakfa-server-stop.sh.Он продолжает перезапуск после принудительного завершения процесса.Я думаю, что где-то есть тупик, но в чем причина?
Я не могу понять, потому что даже если есть ошибка при подключении kafka, это не должно влиять на брокера.
Я быценим вашу помощь.