- 查看集群中的kafka topics消息队列 清单
/opt/cloudera/parcels/CDH/bin/kafka-topics –bootstrap-server hadoop103:9092,hadoop104:9092 –list - 创建集群中新的消息队列
/opt/cloudera/parcels/CDH/bin/kafka-topics –bootstrap-server hadoop103:9092,hadoop104:9092 –create –replication-factor 1 –partitions 1 –topic sparkstreaming - 删除队列 first
/opt/cloudera/parcels/CDH/bin/kafka-topics –delete –bootstrap-server hadoop103:9092,hadoop104:9092 –topic first
- 查看first队列详情
/opt/cloudera/parcels/CDH/bin/kafka-topics –bootstrap-server hadoop103:9092,hadoop104:9092 –describe –topic first - 往first 队列中生产数据
/opt/cloudera/parcels/CDH/bin/kafka-console-producer –broker-list hadoop103:9092,hadoop104:9092 –topic first - 消费first队列中的数据
/opt/cloudera/parcels/CDH/bin/kafka-console-consumer –bootstrap-server hadoop103:9092,hadoop104:9092 –topic first
作者 admin
张宴银，大数据开发工程师