一个简单的聊天群

先创建一个名为qq的Topic。

> ./bin/kafka-topics.sh --create --bootstrap-server 172.16.185.176:9092 --replication-factor 1 --partitions 2 --topic qq
Created topic qq.

然后再启动两个生产者Producer和两个消费者Consumer。

# 先启动两个Producer
> ./bin/kafka-console-producer.sh --broker-list 172.16.185.176:9092 --topic qq
>
> ./bin/kafka-console-producer.sh --broker-list 172.16.185.176:9092 --topic qq
>

# 再启动两个Consumer
> ./bin/kafka-console-consumer.sh --bootstrap-server 172.16.185.176:9092 --from-beginning --topic qq

> ./bin/kafka-console-consumer.sh --bootstrap-server 172.16.185.176:9092 --from-beginning --topic qq

用Kakfa创建的QQ群

启动之后，生产者Producer就可以自由地给消费者Consumer发送消息了。

这里的生产者Producer就相当于群主和副群主，而消费者Consumer则相当于群里面的成员。

唯一美中不足的是，群成员都被禁言了，只有群主（也就是生产者Producer）才能发消息。

---

感谢支持

更多内容，请移步《超级个体》。