Kafka程序例子
Kafka安装安装Kafka前需要安装Zookeeper,因为Kafka需要Zookeeper做协调(Zookeeper不会参考Linux安装Zookeeper,我是安装在windows环境下,步骤差不多)安装好了之后安装Kafka Kafka下载地址安装完成后:1、启动zookeeper2、启动Kafkacmd命令进入Kafka安装目录 ,目录位置如下进入这个目录之后 输入启动...
Kafka安装
安装Kafka前需要安装Zookeeper,因为Kafka需要Zookeeper做协调(Zookeeper不会参考Linux安装Zookeeper,我是安装在windows环境下,步骤差不多)安装好了之后安装Kafka Kafka下载地址
安装完成后:
1、启动zookeeper
2、启动Kafka cmd命令进入Kafka安装目录 ,目录位置如下
进入这个目录之后 输入启动命令 : .\bin\windows\kafka-server-start.bat .\config\server.properties
启动成功!
用Kafka自带消息生产者消费者演示消息队列
在安装目录下用topic创建topic:
cmd命令:.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic test-kafka-topic (不懂参数可以参考博主上一篇博客基础概念)
可以看见创建了一个test-kafka-topic 的topic
查看已经存在的主题: .\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
创建一个生产者命令:.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test-kafka-topic
例外启动一个cmd 创建消费者: .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-kafka-topic --from-beginning
–from-beginning 指从头开始消费
谢谢观看,下一篇用Java代码编写Kafka简单入门例子
更多推荐
所有评论(0)