ch habe bereits angefangen, Kafka zu lernen. Probieren Sie grundlegende Operationen aus. Ich habe an einem Punkt festgehalten, der sich mit den "Brokern" befasst.

Meine 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 (letzter Aufruf zuletzt): Datei "", Zeile 1, in Datei "/usr/local/lib/python2.7/dist-packages/kafka/consumer/group.py", Zeile 284, indri self._client = KafkaClient (metrics = self._metrics, ** self.config) Datei "/usr/local/lib/python2.7/dist-packages/kafka/client_async.py", Zeile 202, indri self.config ['api_version'] = self.check_version (timeout = check_timeout) Die Datei "/usr/local/lib/python2.7/dist-packages/kafka/client_async.py" in Zeile 791 in check_version löst Fehler aus. NoBrokersAvailable () kafka.errors.NoBrokersAvailable: NoBrokersAvailable