我想将我的Kafka集群从2.7升级到2.8,升级指南中提到要检查日志格式版本,如何检查?
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 ...
字符串问候!
1条答案
按热度按时间wsewodh21#
如果你没有指定版本,它会使用该版本的默认值。顺便说一下,我建议你显式地设置版本。
您可以通过查看启动时的代理日志来检查版本:
字符串
问候!