Клиент PyKafka подключается не к тому брокеру

Question

Я не могу понять, что происходит.

Я запустил продюсера, выполнив команду:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

и потребителя:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

Но когда яdo

client = KafkaClient('localhost:9092')

Всегда написано: Failed to connect newly created broker for b'adnans-mbp':9092

Error encountered when producing to broker b'adnans-mbp':9092. Retrying.
Error encountered when producing to broker b'adnans-mbp':9092. Retrying.

При отправке сообщений я ничего не получаю в программе.Хотя на консоли он получает сообщения.

Что я не так делаю?

Answer 1

Проверьте свойство listeners в файле конфигурации server.properties.Похоже, ваш экземпляр KafkaClient не может связаться с брокером, который вы используете локально, возможно, из-за перевода имени хоста, который превращает localhost в adnans-mbp.

См. Также https://github.com/Parsely/pykafka/issues/812