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