升级前注意做好集群的备份

一、解压

sudosu-tar-zxvfkafka_2.12-3.8.1.tgzsudoln-s/opt/kafka_2.12-3.8.1 /opt/kafka

二、配置server.properties

hostname -i 获取本机ip ，修改配置文件中/opt/kafka/conf/server.properties 中的localhost为本机ip，如下图有两处需要修改

hostname-ivim/opt/kafka/conf/server.properties

三、集群初始化

# 产生集群IDKAFKA_CLUSTER_ID="$(/opt/kafka/bin/kafka-storage.sh random-uuid)"# 格式化集群/opt/kafka/bin/kafka-storage.shformat-t$KAFKA_CLUSTER_ID-c/opt/kafka/config/kraft/server.properties# 格式化日志# Formatting /tmp/kraft-combined-logs with metadata.version 3.8-IV0.

四、启动kafka

nohup/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/kraft/server.properties>/opt/kafka/kafka-server.log2>&1&

测试kafka是否正常：

# 创建一个topic/opt/kafka/bin/kafka-topics.sh--create--topicquickstart-events --bootstrap-server localhost:9092# 查看topic描述/opt/kafka/bin/kafka-topics.sh--describe--topicquickstart-events --bootstrap-server localhost:9092# 生产一些数据/opt/kafka/bin/kafka-console-producer.sh--topicquickstart-events --bootstrap-server localhost:9092111222# 消费数据/opt/kafka/bin/kafka-console-consumer.sh--topicquickstart-events --from-beginning --bootstrap-server localhost:9092111222

五、创建topic

/opt/kafka/bin/kafka-topics.sh--create--bootstrap-server localhost:9092 --replication-factor1--partitions1--if-not-exists--topica1

查看topic

/opt/kafka/bin/kafka-topics.sh--describe--topica1 --bootstrap-server localhost:9092 Topic: a1 TopicId: Dhxy7-NES7ujY_5kfdMe3Q PartitionCount:1ReplicationFactor:1Configs:segment.bytes=1073741824Topic: mg_auditlog2_pro Partition:0Leader:1Replicas:1Isr:1Elr: LastKnownElr:

六、验证

/opt/kafka/bin/kafka-topics.sh--list--bootstrap-server ip:9092 /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server ip:9092--topica1 --from-beginning