kafka2.8.1升级至3.4.0教程_kafka3.4.0

上传、解压新版本kafka到/opt/kafka：kafka_2.12-3.4.0.tgz

将旧版本的config/server.properties拷贝覆盖到新版本，并且修改以下配置

authorizer.class.name=kafka.security.authorizer.AclAuthorizer
1

将旧版本的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 "$@" 
1

修改启动脚本：vi startKafka.sh

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
1
2

启动测试即可