Мой кластер kafka имеет 9 узлов.
Bcz Я пытаюсь реализовать SSL, в настоящее время я пытаюсь установить SSL только на 1 узле.
Теперь, когда я сделал SSLнастроить узел с идентификатором 1001 и для проверки этого я создал тему «SSLtest», в которой есть лидер и реплика только на 1001.
Когда я пытаюсь передать данные от производителя консоли на том же компьютере в тему«SSLtest» (т. Е. 1001), он пытается подключиться к машине 1006, как записывается в журнале:
Error when handling request {topics=[SSLtest],allow_auto_topic_creation=true} (kafka.server.KafkaApis)
kafka.common.BrokerEndPointNotAvailableException: End point with listener name SSL not found for broker 1006.
Почему он не может отправить данные на 1001 напрямую.Что он пытается сделать на 1006.