查找Kafka Message版本



0.10.1.1Broker上的默认server.properties没有显式定义log.message.format.version。尽管它应该是相同的卡夫卡API版本;有办法找到它吗?

如果它没有在broker属性文件中明确定义,那么log.message.format.version将与broker版本匹配。

您可以从每个版本的配置文档中看到这一点。例如,对于0.10.1.1,根据0.10.1文档,它是0.10.1-IV2

仔细检查的一种方法是查看broker日志。启动时,代理会转储其配置,包括属性文件中尚未覆盖的设置。

在您的案例中,应该包括log.message.format.version=0.10.1-IV2

最新更新