我的消息中间件 kafka入门

https://blog.csdn.net/tangdong3415/article/details/53432166

工作原理：

1 一个分区partion和一个消费者consumer对应

安装使用：

第一步：下载kafka   brew install kafaka

第二步：启动服务（zookeeper kafka）

zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties & kafka-server-start /usr/local/etc/kafka/server.properties

第三步：创建并查看主题

kafka-topics--create--zookeeperlocalhost:2181--replication-factor1--partitions1--topic tuzisir

查看所有篮子

kafka-topics --list--zookeeper localhost:2181

第四步：

发送消息

kafka-console-producer --broker-listlocalhost:9092--topic tuzisir

接受消息

kafka-console-consumer --bootstrap-server localhost:9092--topic tuzisir --from-beginning

java操作：