-
上传、解压新版本kafka到/opt/kafka:kafka_2.12-3.4.0.tgz
-
将旧版本的config/server.properties拷贝覆盖到新版本,并且修改以下配置
authorizer.class.name=kafka.security.authorizer.AclAuthorizer
-
将旧版本的kafka-broker-jaas.conf文件覆盖到新版本(acl权限,没做可以忽略)
ps:如果还修改了config底下的其他配置文件,酌情进行修改 -
修改启动配置:/opt/kafka/kafka_2.12-3.4.0/bin/kafka-server-start.sh
脚本最后一行配置环境变量如下:exec $base_dir/kafka-run-class.sh $EXTRA_ARGS -Djava.security.auth.login.config=/opt/kafka/kafka_2.12-3.4.0/config/kafka-broker-jaas.conf kafka.Kafka "$@"
-
修改启动脚本:vi startKafka.sh文章来源:https://www.toymoban.com/news/detail-660563.html
cd /opt/kafka/kafka_2.12-3.4.0/bin nohup ./kafka-server-start.sh /opt/kafka/kafka_2.12-3.4.0/config/server.properties >>/opt/kafka/log/kafkaLog
-
启动测试即可文章来源地址https://www.toymoban.com/news/detail-660563.html
到了这里,关于kafka2.8.1升级至3.4.0教程的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!