kafka安装指南

安装环境

• ubuntu-20.04.3 LTS

• jdk-1.8.0_321

• apache-zookeeper-3.6.3

• kafka-3.1.0

安装 kafka

在 kafka 官网 下载所需版本的 kafka 安装包，解压到 /usr/local 文件夹中，并在 ~/.bashrc 中设置环境变量。

# set kafka home
export KAFKA_HOME=/usr/local/kafka
export PATH=$KAFKA_HOME/bin:$PATH

修改 kafka 配置文件

server.properties

broker.id=1
delete.topic.enable=true
listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092

测试 kafka

启动 kafka

$KAFKA_HOME/bin/kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties

创建主题

kafka-topics.sh --create   --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic kafka_test
kafka-topics.sh --list     --bootstrap-server localhost:9092
kafka-topics.sh --describe --bootstrap-server localhost:9092

生产者

kafka-console-producer.sh --broker-list localhost:9092 --topic kafka_test

消费者

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic kafka_test --from-beginning

删除主题

kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic kafka_test

停止 kafka

$KAFKA_HOME/bin/kafka-server-stop.sh