下面给你一个**在 Debian 上安装并配置 Kafka(单节点为例)**的简明流程,适合新手快速跑起来。
sudo apt update
sudo apt install -y default-jdk
验证:
java -version
cd /opt
sudo wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
sudo tar -xzf kafka_2.13-3.7.0.tgz
sudo mv kafka_2.13-3.7.0 kafka
主要配置文件在:
/opt/kafka/config/server.properties
编辑:
sudo nano /opt/kafka/config/server.properties
常见关键配置(单节点):
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
num.partitions=1
如果是服务器远程访问,把 localhost 改成服务器 IP。
/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
查看进程:
jps
应看到 QuorumPeerMain 和 Kafka
/opt/kafka/bin/kafka-topics.sh --create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 --replication-factor 1
/opt/kafka/bin/kafka-console-producer.sh \
--topic test --bootstrap-server localhost:9092
/opt/kafka/bin/kafka-console-consumer.sh \
--topic test --from-beginning --bootstrap-server localhost:9092
可写成 systemd 服务,或简单加到 rc.local:
/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
sleep 5
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
9092log.dirs,不要用 /tmp如果你愿意,我可以:
你想走到哪一步?