Traceback (most recent call last): File "producer.py", line 6, in <module> producer = KafkaProducer(bootstrap_servers='localhost:9092') File "/home/hadoop/.local/lib/python3.5/site-packages/kafka/producer/kafka.py", line 383, in __init__ **self.config) File "/home/hadoop/.local/lib/python3.5/site-packages/kafka/client_async.py", line 244, in __init__ self.config['api_version'] = self.check_version(timeout=check_timeout) File "/home/hadoop/.local/lib/python3.5/site-packages/kafka/client_async.py", line 900, in check_version raise Errors.NoBrokersAvailable() kafka.errors.NoBrokersAvailable: NoBrokersAvailable
时间: 2023-12-12 20:03:16 浏览: 49
这个错误是由于 KafkaProducer 没有连接到 Kafka 集群引起的。你需要确保 Kafka 集群已经启动并且使用正确的 IP 和端口连接到 Kafka 集群。另外,你还需要检查 Kafka 生产者的配置,确保它们正确地配置了 Kafka 集群的 IP 和端口。如果你已经检查了这些问题,但是仍然无法解决问题,那么你可以查看 Kafka 集群的日志以获取更多的信息,以确定问题的根本原因。
相关问题
Traceback (most recent call last): File "D:/Snake.py", line 473, in <module> inst1 = Snake()
这是一个Python程序出现的错误信息,具体的错误原因需要查看代码才能确定。根据错误信息可以看出,在D:/Snake.py文件的第473行,创建了一个名为inst1的Snake对象,但是在创建对象时出现了错误。可能的原因包括:类定义有误、代码逻辑有误、调用了不存在的方法或属性等。需要进一步查看代码才能确定具体的原因。
Traceback (most recent call last): File "E:\AdaBoost\adaboost.py", line 11, in <module> dataset = pd.read_csv(file_path)
这个 traceback 的错误信息与上一个类似,但是这次错误是在尝试读取 csv 文件时发生的。根据错误信息,`pd.read_csv()` 函数无法读取名为 `file_path` 的文件。
这个问题可能是由于文件路径不正确或文件格式不正确导致的。请尝试以下方法来解决这个问题:
1. 确保文件路径是正确的。可以使用 `print(file_path)` 语句来打印文件路径,以确保它与预期的一样。
2. 确保文件格式是正确的。`pd.read_csv()` 函数只能读取 CSV 格式的文件。如果你的文件不是 CSV 格式,请尝试使用适当的函数(例如 `pd.read_excel()` 或 `pd.read_table()`)来读取文件。
3. 检查文件编码是否正确。如果文件采用了非标准的编码格式,可以使用 `encoding` 参数来指定正确的编码。例如,如果文件使用 UTF-16 编码,你可以将 `pd.read_csv()` 函数修改为 `pd.read_csv(file_path, encoding='utf-16')`。
希望这些方法可以帮助你解决问题。