Kafka下载地址:https://kafka.apache.org/downloads
1解压 软件,然后复制 config 目录下的 server.properties文件 三份
2 文件内容
server1.properties
broker.id=1 listeners = PLAINTEXT://:9092 advertised.listeners=PLAINTEXT://10.14.9.108:9092 num.network.threads=3 num.io.threads=8 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 log.dirs=/Users/zhihu/soft-learn/kafka-3.1.0/logs/log1 num.partitions=1 num.recovery.threads.per.data.dir=1 offsets.topic.replication.factor=1 transaction.state.log.replication.factor=1 transaction.state.log.min.isr=1 log.retention.hours=168 log.segment.bytes=1073741824 log.retention.check.interval.ms=300000 zookeeper.connect= localhost:2181,localhost:2182,localhost:2183 zookeeper.connection.timeout.ms=18000 group.initial.rebalance.delay.ms=0
server2.properties
broker.id=2 listeners = PLAINTEXT://:9093 advertised.listeners=PLAINTEXT://10.14.9.108:9093 num.network.threads=3 num.io.threads=8 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 log.dirs=/Users/zhihu/soft-learn/kafka-3.1.0/logs/log2 num.partitions=1 num.recovery.threads.per.data.dir=1 offsets.topic.replication.factor=1 transaction.state.log.replication.factor=1 transaction.state.log.min.isr=1 log.retention.hours=168 log.segment.bytes=1073741824 log.retention.check.interval.ms=300000 zookeeper.connect= localhost:2181,localhost:2182,localhost:2183 zookeeper.connection.timeout.ms=18000 group.initial.rebalance.delay.ms=0
server3.properties
broker.id=3 listeners = PLAINTEXT://:9094 advertised.listeners=PLAINTEXT://10.14.9.108:9094 num.network.threads=3 num.io.threads=8 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 log.dirs=/Users/zhihu/soft-learn/kafka-3.1.0/logs/log3 num.partitions=1 num.recovery.threads.per.data.dir=1 offsets.topic.replication.factor=1 transaction.state.log.replication.factor=1 transaction.state.log.min.isr=1 log.retention.hours=168 log.segment.bytes=1073741824 log.retention.check.interval.ms=300000 zookeeper.connect= localhost:2181,localhost:2182,localhost:2183 zookeeper.connection.timeout.ms=18000 group.initial.rebalance.delay.ms=0
3 在终端中执行一下命令
nohup /Users/myh/soft-learn/kafka-3.1.0/bin/kafka-server-start.sh /Users/myh/soft-learn/kafka-3.1.0/config/server3.properties > /Users/myh/soft-learn/kafka-3.1.0/logs/start.log 2>&1 & nohup /Users/myh/soft-learn/kafka-3.1.0/bin/kafka-server-start.sh /Users/myh/soft-learn/kafka-3.1.0/config/server2.properties > /Users/myh/soft-learn/kafka-3.1.0/logs/start.log 2>&1 & nohup /Users/myh/soft-learn/kafka-3.1.0/bin/kafka-server-start.sh /Users/myh/soft-learn/kafka-3.1.0/config/server1.properties > /Users/myh/soft-learn/kafka-3.1.0/logs/start.log 2>&1 &
到此为止,去看下 server.log 这个文件,你会发现启动成功了
我们接下来测试这个集群的情况,
使用 SpringBoot 与 Kafka 的整合了,项目地址:



