confluent kafka local:使用confluent kafka的简单本地运行Apache Kafka实现 源码

融合卡夫卡本地 一个简单的本地主机,使用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