Сообщение о проблеме здесь.Производитель скинул ошибки ниже.Прождал час или около того, и ошибка ушла.Но, хотя у меня была ошибка, я мог перечислять темы, используя инструмент Kafka, в то время как API-интерфейс Kafka Python не работал:
kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic tweets
Вот ошибка из программы python:
INFO: kafka.producer.kafka: Продолжение принудительного закрытия производителя, так как ожидающие запросы не могут быть выполнены в течение времени ожидания 0.
Использование
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='localhost:9092')