出现"无可用经纪人错误"通常是因为Apache Kafka集群中没有可用的经纪人(broker)。下面是一个解决该问题的Python代码示例:
from kafka import KafkaProducer
bootstrap_servers = 'localhost:9092' # 替换为你的Kafka集群的bootstrap服务器地址
# 创建Kafka生产者
producer = KafkaProducer(bootstrap_servers=bootstrap_servers)
# 发送消息到指定主题
topic = 'test_topic' # 替换为你的Kafka主题
message = b'Hello, Kafka!' # 替换为你要发送的消息
try:
# 尝试发送消息
producer.send(topic, message)
print('Message sent successfully!')
except Exception as e:
print(f'Failed to send message: {e}')
# 关闭Kafka生产者连接
producer.close()
请确保你已经安装了kafka-python
库,可以通过以下命令进行安装:
pip install kafka-python
如果你仍然遇到"无可用经纪人错误",请确保以下几点:
希望以上代码和解决方法能够帮助你解决问题。如果问题仍然存在,请提供更多详细信息,以便我们能够更好地帮助你。