我是使用 python 生成消息,但我得到了这个异常,在我的脚本下面是..
`from kafka import KafkaProducer producer = KafkaProducer(bootstrap_servers='192.168.1.6:9092') producer.send('test', b'Welcome Nagarajan').get(timeout=60)
收到错误消息...
回溯(最后一次调用):文件“”,第 1 行,文件“/usr/local/lib/python2.7/dist-packages/kafka/producer/kafka.py”,第 245 行,init self.config ['api_version'] = client.check_version() 文件“/usr/local/lib/python2.7/dist-packages/kafka/client_async.py”,第 607 行,在 check_version connect() 文件“/usr/local/ lib/python2.7/dist-packages/kafka/client_async.py”,第 575 行,在连接中引发 Errors.NodeNotReadyError(node_id) kafka.common.NodeNotReadyError: None