融合卡夫卡本地
一个简单的本地主机，使用confluent-kafka运行Apache Kafka实现。
此实现基于，但我需要更轻便的版本进行开发/研究，并且可以从主机进行访问（我不需要额外的容器）而不会弄乱我的机器。 有助于了解Zookeeper（配置）与Kafka Broker之间的通信。
要求
码头工人
Python 3.8以上
Python诗歌（测试所需）
我的 （可选）
发起
make run-kafka
make install
make test-produce
make test-consume
预期的回应
make test-produce
info: server:port is localhost:9092
debug: Message delivered to test_topic, partition 0: {"key": "244a5d38de0635526
2021-04-06 11:07:23
8KB
1
配套视频：https://space.bilibili.com/320773563/channel/detail?cid=174425
2021-04-05 12:02:32
390.77MB
1
SpringBoot整合kafka代码，两个工程 一个消费者 一个生产者，利用定时任务和restapi发送消息，自动分配分区消费和指定分区消费，再也不用写死分区了真好。代码简洁。欢迎大家下载。
2021-04-03 23:21:22
62KB
1