Kafka系列之:Kafka broker does not support the ‘MetadataRequest_v0‘ Kafka protocol.
Kafka系列之:Kafka broker does not support the 'MetadataRequest_v0' Kafka protocol.
- 一、完整报错
- 二、错误原因
- 三、解决方法
一、完整报错
- kafka.errors.IncompatibleBrokerVersion: IncompatibleBrokerVersion: Kafka broker does not support the ‘MetadataRequest_v0’ Kafka protocol.
二、错误原因
- Kafka 客户端(如 kafka-python 或其他客户端库)尝试使用 MetadataRequest_v0 协议与 Kafka 代理通信,但代理不支持该版本。
通常,较新的 Kafka 代理(如 Kafka 2.x 或 3.x)可能不再支持较旧的协议版本(如 v0)。
三、解决方法
- 显式设置协议版本
- 如果客户端支持,可以手动指定更高的协议版本。例如,在 kafka-python 中,可以尝试:
from kafka import KafkaProducerproducer = KafkaProducer(bootstrap