我是使用python生成消息,但我得到这个例外,在我的脚本下面是..

`来自kafka import KafkaProducer producer = KafkaProducer(bootstrap_servers ='192.168.1.6:9092')producer.send('test',b'Welcome Nagarajan') . get(timeout = 60)

收到错误消息...

回溯(最近一次调用最后一次):文件“", line 1, in File " /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中连接()文件"/usr/local/lib/python2.7/dist-packages/kafka/client_async.py",第575行,在连接中引发错误.NodeNotReadyError(node_id)kafka.common.NodeNotReadyError:无