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

5lwkijsr  于 12个月前  发布在  Apache
关注(0)|答案(1)|浏览(201)

我想将我的Kafka集群从2.7升级到2.8,升级指南中提到要检查日志格式版本,如何检查?

wsewodh2

wsewodh21#

如果你没有指定版本,它会使用该版本的默认值。顺便说一下,我建议你显式地设置版本。
您可以通过查看启动时的代理日志来检查版本:

[2023-11-16 12:07:45,464] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2023-11-16 12:07:48,176] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2023-11-16 12:07:49,031] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
[2023-11-16 12:07:49,047] INFO starting (kafka.server.KafkaServer)
...
[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
    ...

字符串
问候!

相关问题