Eu já comecei a aprender Kafka. Tentando operações básicas nele. Entrei em um ponto sobre os "Corretores".

Meu kafka está em execução, mas quando eu quero criar uma partição.

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

traceback (última chamada mais recente): arquivo "", linha 1, no arquivo "/usr/local/lib/python2.7/dist-packages/kafka/consumer/group.py", linha 284, eminiciar self._client = KafkaClient (métricas = self._metrics, ** self.config) Arquivo "/usr/local/lib/python2.7/dist-packages/kafka/client_async.py", linha 202, eminiciar self.config ['api_version'] = self.check_version (timeout = check_timeout) Arquivo "/usr/local/lib/python2.7/dist-packages/kafka/client_async.py", linha 791, em check_version raise Errors.NoBrokersAvailable () kafka.errors.NoBrokersAvailable: NoBrokersAvailable