如何在我的 Apache Kafka 集群中检查 log.message.format.version

Question

我想将我的 Kafka 集群从 2.7 升级到 2.8。升级指南中提到检查日志格式版本。如何检查这个？

Answer 1

如果您不指定版本，则采用该版本的默认版本。 顺便说一句，我建议您明确设置版本。

您可以通过查看代理启动时的日志来检查版本：

...
2023-11-16 12:07:52,337] WARN No meta.properties file under dir /data/kafka/logdir/meta.properties (kafka.server.BrokerMetadataCheckpoint)
[2023-11-16 12:07:52,802] INFO KafkaConfig values: 
    advertised.listeners = PLAINTEXT://192.168.1.134:9092
    alter.config.policy.class.name = null
    alter.log.dirs.replication.quota.window.num = 11
    alter.log.dirs.replication.quota.window.size.seconds = 1
    ...
    log.message.downconversion.enable = true
    log.message.format.version = 3.0-IV1
    log.message.timestamp.difference.max.ms = 9223372036854775807
    log.message.timestamp.type = CreateTime
    ...

问候！