linux单机版kafka启动命令
程序员文章站
2022-05-27 16:41:54
...
需要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命令