kafka的启动与测试

Posted patrick-king

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafka的启动与测试相关的知识,希望对你有一定的参考价值。

kafka 相关的知识
进入 /usr/local/kafka 目录下
查看端口
vim zookeeper.properties
#文件中dataDir=/tmp/zookeeper代表zookeeper数据存储路径,clientPort=2182代表zookeeper的端口号为:2182,消费者需要监听的端口
vim server.properties
#倒数第三行 ‘zookeeper.connect=localhost:2182’ 代表连接zookeeper, port是端口9091

启动zookeeper命令
nohup /usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties &
启动server命令
nohup /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &

创建topic
bin/kafktopics.sh --create --zookeeper localhost:2182 --replication-factor 1 --partitions 1 --topic test
查看topic
bin/kafka-topics.sh --list --zookeeper localhost:2182
创建生产者(在A窗口)(可能由于kafka版本不同,命令参数可能不同,可以使用bin/kafka-console-producer.sh --topic test 看下)
bin/kafka-console-producer.sh --broker-list 192.168.90.123:9093 --topic test
然后就可输入测试的内容了,回车发送
创建消费者(在B窗口)(可能由于kafka版本不同,命令参数可能不同,可以使用bin/kafka-console-consumer.sh --topic test 看下)
bin/kafka-console-consumer.sh --zookeeper localhost:2182 --topic test --from-beginning
启动完就可以接受生产者发过来的内容了
删除topic
bin/kafka-topics.sh --delete --zookeeper localhost:2182 --topic test

以上是关于kafka的启动与测试的主要内容,如果未能解决你的问题,请参考以下文章

kafka zookeeper学习 测试kafka与zookeeper环境

053 kafka自带的生产者与消费者测试

Kafka在Mac下的安装与使用

如何在 @ContextConfiguration 初始化程序之前启动 kafka 测试容器?

Kafka Consumer 启动测试类

windows安装kafka过程 本地测试外赋快速启动小脚本