如果您想将 Apache Kafka 升级到新的补丁版本,可以按照以下步骤进行:
下载新的 Kafka 发行版并解压缩。
检查您的配置文件并将其与新的 Kafka 发行版进行比较。如果需要,进行相应的更新。
停止正在运行的 Kafka 进程。
将新的 Kafka 发行版复制到 Kafka 安装目录。
应用新的补丁:
$ bin/kafka-run-class.sh kafka.admin.AdminClient --bootstrap-server localhost:9092 --command-config config/client-ssl.properties --upgrade-deprecated=TRUE --upgrade-from-version=1.0.2 --upgrade-to-version=1.0.3 --dry-run
注:请将命令中的 bootstrap-server、command-config、upgrade-from-version 和 upgrade-to-version 替换为自己的相应值。
检查命令的输出以确保升级过程不会导致任何问题。
如果命令的输出没有问题,则应用升级:
$ bin/kafka-run-class.sh kafka.admin.AdminClient --bootstrap-server localhost:9092 --command-config config/client-ssl.properties --upgrade-deprecated=TRUE --upgrade-from-version=1.0.2 --upgrade-to-version=1.0.3
确认升级已成功完成。
启动 Kafka 进程并确保它正在运行。
请注意,如果您的 Kafka 集群由多个代理组成,则需要对每个代理进行升级,以确保该集群是向后兼容的。