Ich habe bereits begonnen, Kafka zu lernen. Grundlegende Operationen darauf versuchen. Ich bin auf einen Punkt gestoßen, der über die "Broker" spricht.NoBrokersVerfügbar: NoBrokersAvailable-Kafka Fehler
Mein Kafka läuft, aber wenn ich eine Partition erstellen möchte.
from kafka import TopicPartition
(ERROR THERE) consumer = KafkaConsumer(bootstrap_servers='localhost:1234')
consumer.assign([TopicPartition('foobar', 2)])
msg = next(consumer)
Traceback (jüngste Aufforderung zuletzt): Datei "" Linie 1 in File „/usr/local/lib/python2.7/dist-packages/kafka/consumer/group. py ", Zeile 284, in init selb._client = KafkaClient (metrics = self._metrics, ** self.config) Datei" /usr/local/lib/python2.7/dist-packages/kafka/client_async .py ", Zeile 202, in init self.config ['api_version'] = self.check_version (timeout = check_timeout) Datei" /usr/local/lib/python2.7/dist-packages/ kafka/client_async.py“, Linie 791, in check_version raise Errors.NoBrokersAvailable() kafka.errors.NoBrokersAvailable: NoBrokersAvailable
überprüft Schritte zum Erstellen einer Kafka Data-Pipeline. Folgen Sie dem Link unten. https://stackoverflow.com/questions/35689238/kafka-python-producer-is-not-able-to-connect/49212019#49212019 – user2468325