Я уже начал изучать Кафку. Пробуем основные операции на нем. Я остановился на вопросе о «Брокерах».

Моя Кафка работает, но когда я хочу создать раздел.

 from kafka import TopicPartition
(ERROR THERE) consumer = KafkaConsumer(bootstrap_servers='localhost:1234')
 consumer.assign([TopicPartition('foobar', 2)])
 msg = next(consumer)

traceback (последний вызов был последним): файл "", строка 1, в файле "/usr/local/lib/python2.7/dist-packages/kafka/consumer/group.py", строка 284, вв этом self._client = KafkaClient (metrics = self._metrics, ** self.config) Файл "/usr/local/lib/python2.7/dist-packages/kafka/client_async.py", строка 202, вв этом self.config ['api_version'] = self.check_version (timeout = check_timeout) Файл "/usr/local/lib/python2.7/dist-packages/kafka/client_async.py", строка 791, в check_version поднять Errors.NoBrokersAvailable () kafka.errors.NoBrokersAvailable: NoBrokersAvailable