推荐订阅源

初始化集群

       uuid只要在一台机器上执行即可,其他主机复制uuid的值即可
       uuid=bin/kafka-storage.sh random-uuid
       echo $uuid

     每台主机上执行以上命令
       bin/kafka-storage.sh format -t $(uuid) -c config/kraft/server.properties

       bin/kafka-server-start.sh --daemon config/kraft/server.properties

       jdk要17以上

配置文件修改

cat /config/kraft/server.properties
process.roles=broker,controller
node.id=1
controller.quorum.voters=1@43.68.1.60:9093,2@43.68.1.61:9093,3@43.68.1.62:9093
listeners=PLAINTEXT://:9092,CONTROLLER://:9093
advertised.listeners=PLAINTEXT://43.68.1.60:9092
inter.broker.listener.name=PLAINTEXT
controller.listener.names=CONTROLLER
listener.security.protocol.map=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
log.dirs=/app/kafka/logs
offsets.topic.replication.factor=3
transaction.state.log.replication.factor=3
auto.create.topics.enable=true
log.retention.hours=6
message.max.bytes=6291457
num.partitions=4

View Code

注册服务

[Unit]
Description=kafka
Wants=network-online.target

[Service]
Type=simple
User=root
Group=root

WorkingDirectory=/app/bitnami/kafka
ExecStart=/app/bitnami/kafka/bin/kafka-server-start.sh /app/bitnami/kafka/config/kraft/server.properties


KillSignal=SIGTERM
TimeoutStopSec=30
SendSIGKILL=no
SuccessExitStatus=143

kafka.service

每个node启动间隔不要太大