欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

linux单机版kafka启动命令

程序员文章站 2022-05-27 16:41:54
...

linux单机版kafka启动命令

 需要java环境,推荐1.8以上


下载kafka,解压,进入kafka的bin目录

启动zookeeper(Kafka 0.5.x版本以上已经自带ZooKeper)

nohup ./zookeeper-server-start.sh ../config/zookeeper.properties &

备注:自测的话直接使用自带的zookeeper就行,要是生产的话,建议分离,另起一套。 

启动kafka

nohup ./kafka-server-start.sh ../config/server.properties &

查看zookeeper和kafka是否启动

netstat -tanlp | egrep "2181|9092"

创建主题:test

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

生产主题:test

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

消费主题:test

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test 

查看所有主题

 ./kafka-topics.sh  --zookeeper localhost:2181 --list

查看指定主题描述信息

./kafka-topics.sh --describe  --zookeeper localhost:2181  --topic test

上一篇: 单机版kafka安装

下一篇: tar命令