码迷,mamicode.com
首页 > 其他好文 > 详细

kafka单机安装

时间:2020-03-07 10:13:38      阅读:73      评论:0      收藏:0      [点我收藏+]

标签:消息队列   运行   alt   OLE   broker   href   actor   blank   body   

引用:https://www.cnblogs.com/adolfmc/p/7345333.html

创建一个消息队列:

bin/kafka-topics.sh --create --replication-factor 1 --partitions 1 --topic test --zookeeper localhost:2181/kafka

  创建队列的时候,replication-factor只能是1个,因为是单节点,而partitions分区可以是1个或者2个都可以,测试环境建议是1个即可

  然后,创建一个消费者:

bin/kafka-console-consumer.sh --zookeeper localhost:2181/kafka --topic test

  此时,命令行会进入运行状态,界面就卡住不动了,然后再新建一个窗口,进入kafka目录,继续创建一个生产者:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

  同样这个时候命令行进入运行状态,我们输入一个字符串:Hello Kafka!

  技术图片

  此时打开刚才创建消费者的窗口,会看到刚才的输入消息被消费了

  技术图片

  到现在,Kafka单机消息队列基本的配置和运行都是正常的,单机环境配置基本上就是这些

 
分类: bigdata

 

kafka单机安装

标签:消息队列   运行   alt   OLE   broker   href   actor   blank   body   

原文地址:https://www.cnblogs.com/breakingbrad/p/12432057.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!