首页  ·  知识 ·  大数据
Kafka集群的测试和简单试用
网友  CSDN  实践应用  编辑:Osborn   图片来源:网络
搭建了三个节点的Kafka集群,在主节点创建一个topic,作为生产者,两个从节点作为消费者分别看看能否接收数据,进行验证

操作步骤


思路:搭建了三个节点的Kafka集群,在主节点创建一个topic,作为生产者,两个从节点作为消费者分别看看能否接收数据,进行验证


步骤一,在主节点执行


创建topic及查看topic命令


#查看所有topic命令如下

 # kafka-topics.sh -list -zookeeper 192.168.210.70:2181,192.168.210.71:2181,192.168.210.72:2181


# (rf参数副本数,par参数分区数,xubin是topic的名称)创建topic命令如下  

 # kafka-topics.sh --create --zookeeper 192.168.210.70:2181,192.168.210.71:2181,192.168.210.72:2181 --replication-factor 3 --partitions 1 --topic xubin    


在主节点查看topic,发现没有,进行创建topic为xubin,重新进行查看topic,发现存在了!


image.png


同理,一开始在从节点上看不到topic,当在主节点上创建了topic后,在从节点也能查到topic!


image.png


步骤二,在主节点创建生产者,在两个从节点分别创建消费者


开启生产者以及消费者


#开启生产者命令如下:

 # kafka-console-producer.sh --broker-list 192.168.210.70:9092,192.168.210.71:9092,192.168.210.72:9092 --topic xubin     


#开启生产者命令如下:     

 # kafka-console-consumer.sh --zookeeper 192.168.210.70:2181,192.168.210.71:2181,192.168.210.72:2181 --topic xubin --from-beginning  消费者  


在主节点开启生产者:


image.png


在两个从节点分别开启消费者:


image.png


image.png


步骤三,在生产者中输入信息,看消费者中是否能拿到数据


生产者:


image.png


消费者:

image.png


image.png


这里写图片描述


本文作者:网友 来源:CSDN
CIO之家 www.ciozj.com 微信公众号:imciow
   
免责声明:本站转载此文章旨在分享信息,不代表对其内容的完全认同。文章来源已尽可能注明,若涉及版权问题,请及时与我们联系,我们将积极配合处理。同时,我们无法对文章内容的真实性、准确性及完整性进行完全保证,对于因文章内容而产生的任何后果,本账号不承担法律责任。转载仅出于传播目的,读者应自行对内容进行核实与判断。请谨慎参考文章信息,一切责任由读者自行承担。
延伸阅读