kafka基本使用及命令

大数据评论613阅读模式
摘要

kafka基本使用及操作命令

假设zookeeper server及kafka broker的IP都为172.18.245.104,下面是简单使用kafka的过程。

创建topics
kafka-topics --create --zookeeper 172.18.245.104:2181 --topic test --partitions 1  --replication-factor 1
查看topic状态
kafka-topics --describe --zookeeper 172.18.245.104:2181 --topic test
发送消息(producer)
kafka-console-producer --broker-list 172.18.245.104:9092 --topic test
消费消息(consumer )
kafka-console-consumer --bootstrap-server 172.18.245.104:9092 --topic test --from-beginning
查看kafka topic
进入zookeeper目录, /opt/cloudera/parcels/CDH-6.3.0-1.cdh6.3.0.p0.1279813/lib/zookeeper/bin
  • 运行
zkCli.sh
  • 查看
kafka-consumer-groups --list --bootstrap-server 172.18.245.105:9092
kafka-topics --describe --zookeeper 172.18.245.105:2181 --topic mydemo2