0


kafka2.8.1升级至3.4.0教程

  1. 上传、解压新版本kafka到/opt/kafka:kafka_2.12-3.4.0.tgz
  2. 将旧版本的config/server.properties拷贝覆盖到新版本,并且修改以下配置authorizer.class.name=kafka.security.authorizer.AclAuthorizer
  3. 将旧版本的kafka-broker-jaas.conf文件覆盖到新版本(acl权限,没做可以忽略) ps:如果还修改了config底下的其他配置文件,酌情进行修改
  4. 修改启动配置:/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"$@"
  5. 修改启动脚本:vi startKafka.shcd /opt/kafka/kafka_2.12-3.4.0/binnohup ./kafka-server-start.sh /opt/kafka/kafka_2.12-3.4.0/config/server.properties >>/opt/kafka/log/kafkaLog
  6. 启动测试即可
标签: kafka java 分布式

本文转载自: https://blog.csdn.net/weixin_40496191/article/details/129067607
版权归原作者 懒惰の天真热 所有, 如有侵权,请联系我们删除。

“kafka2.8.1升级至3.4.0教程”的评论:

还没有评论