wiki-files/kafka/setup.md

1.7 KiB

title description published date tags editor dateCreated
安装 true 2022-01-18T13:58:48.981Z kafka markdown 2022-01-18T13:27:38.792Z

下载Kafka

传送门

修改配置

修改 zookeeper 配置

打开 config/zookeeper.properties 配置文件

修改配置

clientPort=2181

修改 kafka 配置

打开 config/server.properties 配置文件

取消注释并修改配置

listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://host:9092

启动

进入 bin/ 目录

启动 zookeeper

直接启动

$ ./zookeeper-server-start.sh ../config/zookeeper.properties

后台启动并将日志输入到指定文件

$ nohup ./zookeeper-server-start.sh ../config/zookeeper.properties > ../logs/zookeeper.log 2>&1 &

启动 kafka

直接启动

$ ./kafka-server-start.sh ../config/server.properties

后台启动并将日志输入到指定文件

$ nohup ./kafka-server-start.sh ../config/server.properties > ../logs/kafka.log 2>&1 &

测试

进入 bin/ 目录

添加 topic

$ ./kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic kafkatest

启动 producer

$ ./kafka-console-producer.sh --broker-list localhost:9092 --topic kafkatest

启动 consumer

$ ./kafka-console-consumer.sh --bootstrap-server localhost:9092  --topic kafkatest --from-beginning

测试消息

在 producer 中输入内容并回车,查看 consumer 输出内容是否相同

停止

进入 bin/ 目录

停止 kafka

$ ./kafka-server-stop.sh

停止 zookeeper

$ ./zookeeper-server-stop.sh