准备工作
- 安装java 11
KIP-750: Drop support for Java 8 in Kafka 4.0 (deprecate in 3.0)
Kafka从3.0版本开始废弃Java 8,因此本文采用Java 11.
安装kafka
Kafka目前支持ZooKeeper和KRaft两个模式,本文使用的ZooKeeper.
解压Kafka
tar -xzf kafka_2.13-3.4.0.tgz
cd kafka_2.13-3.4.0
# 创建文件夹保存数据
mkdir -p data/zookeeper
mkdir -p data/kafka-logs
修改配置
- 修改ZooKeeper配置
修改config
文件夹下的zookeeper.properties,将dataDir
修改为指定的数据文件夹。
本文的配置为:
dataDir=/home/sun/kafka_2.13-3.4.0/data/zookeeper
- 修改Kafka配置
修改config
文件夹下的server.properties,将listeners
修改为需要监听的ip和端口,将log.dirs
修改指定的数据文件夹。
本文的配置为:
listeners=PLAINTEXT://192.168.56.151:9092
log.dirs=/home/sun/kafka_2.13-3.4.0/data/kafka-logs
启动程序
# 后台模式启动zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
# 后台模式启动Kafka
bin/kafka-server-start.sh -daemon config/server.properties
验证功能
# 创建topic
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server 192.168.56.151:9092
# 罗列目前的topic
bin/kafka-topics.sh --bootstrap-server 192.168.56.151:9092 --list
# 往topic写消息,使用Ctrl-C取消
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server 192.168.56.151:9092
另开一个终端会话消费消息,使用Ctrl-C取消
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server 192.168.56.151:9092
网友评论