kafka3.8集群搭建

kafka集群需要三台机器搭建，并使用内置zookeeper

IP
10.0.0.1
10.0.0.2
10.0.0.3

安装jdk

# ubuntu
sudo apt install -y openjdk-8-jdk-headless
# centos
sudo yum install -y java-1.8.0-openjdk

下载kafka

wget  https://archive.apache.org/dist/kafka/3.8.1/kafka_2.13-3.8.1.tgz 
# 创建目录
mkdir /data/kafka/logs -p
mkdir /data/kafka/zookeeper_data -p
tar -xvf  kafka_2.13-3.8.1.tgz -C /data/kafka

修改zookeeper配置文件
vim /data/kafka/kafka_2.13-3.8.1/config/zookeeper.properties

zookeeper myid 集群内不能重复的，每台机器设置成不一样的。

echo 1 > /data/zookeeper/myid

dataDir=/data/kafka/zookeeper
# the port at which the clients will connect
clientPort=2181
# disable the per-ip limit on the number of connections since this is a non-production config
maxClientCnxns=0
# Disable the adminserver by default to avoid port conflicts.
# Set the port to something non-conflicting if choosing to enable this
admin.enableServer=false
# admin.serverPort=8080tickTime=2000
initLimit=5
syncLimit=2
server.1=10.0.0.1:2888:3888
server.2=10.0.0.2:2888:3888
server.3=10.0.0.3:2888:3888

修改kafka配置文件
vim /data/kafka/kafka_2.13-3.8.1/config/server.properties

broker.id 每个节点需要不一样

broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://: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=/data/kafka/logs
num.partitions=3
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=24
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
zookeeper.connect=10.0.0.1:2181,10.0.0.2:2181,10.0.0.3:2181zookeeper.connection.timeout.ms=60000
group.initial.rebalance.delay.ms=0
auto.create.topics.enable = true

分别启动zookeeper和kafka

/data/kafka/kafka_2.13-3.8.1/bin/zookeeper-server-start.sh -daemon /data/kafka/kafka_2.13-3.8.1/config/zookeeper.properties && /data/kafka/kafka_2.13-3.8.1/bin/kafka-server-start.sh -daemon /data/kafka/kafka_2.13-3.8.1/config/server.properties

也可以通过配置service启动

先启动zookeeper在启动kafka

vim /etc/systemd/system/zookeeper.service

[Unit]
Description=Zookeeper service
After=network.target[Service]
Type=simple
User=root
Group=root
ExecStart=/data/kafka/kafka_2.13-3.8.1/bin/zookeeper-server-start.sh /data/kafka/kafka_2.13-3.8.1/config/zookeeper.properties
ExecStop=/data/kafka/kafka_2.13-3.8.1/bin/zookeeper-server-stop.sh
Restart=on-failure[Install]
WantedBy=multi-user.target

vim /etc/systemd/system/kafka.service
[Unit]
Description=Apache Kafka server (broker)
After=network.target zookeeper.service[Service]
Type=simple
User=root
Group=root
ExecStart=/data/kafka/kafka_2.13-3.8.1/bin/kafka-server-start.sh /data/kafka/kafka_2.13-3.8.1/config/server.properties
ExecStop=/data/kafka/kafka_2.13-3.8.1/bin/kafka-server-stop.sh
Restart=on-failure[Install]
WantedBy=multi-user.target

测试kafka

cd /data/kafka/kafka_2.13-3.8.1# 创建topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testtopic# 查看topic list
bin/kafka-topics.sh --zookeeper localhost:2181 --list# 控制台生产消息
bin/kafka-console-producer.sh --bootstrap-server 10.0.0.2:9092 --topic testtopic# 控制台消费消息
bin/kafka-console-consumer.sh --bootstrap-server 10.0.0.3:9092 --topic testtopic --from-beginning