本文共 806 字，大约阅读时间需要 2 分钟。

1.Kafka Broker 为bd144 端口为6667

2.zookeeper 为 bd147端口为2181

cd /usr/hdp/2.4.2.0-258/kafka/bin   进入kafka所在目录

开启zookeeper服务

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

开启kafka服务

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

查看topic bdlab01情况

kafka-topics.sh --describe --zookeeper bd147:2181 --topic dblab01  

查看topic列表

kafka-topics.sh --list --zookeeper bd147:2181    

创建topic 命名为bdlab01

./kafka-topics.sh --create --zookeeper bd147:2181 --replication-factor 1 --partitions 1 --topic dblab01  

到opic bdlab01中生产信息

./kafka-console-producer.sh --broker-list bd144:6667 --topic dblab01   

 到topic dblab01拉取信息   

./kafka-console-consumer.sh --zookeeper bd147:2181 --topic dblab01 --from-beginnin   拉取信息

指定abcGroup消费者消费

./kafka-consumer-offset-checker.sh --zookeeper bd147:2181 --topic dpi_sourcedata_topic7 --group abcGroup

转载地址：http://yoksi.baihongyu.com/