私は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 を発生させます