目录

背景

kafka%20%E8%B0%83%E7%94%A8%E9%97%AE%E9%A2%98%E6%A0%B9%E5%9B%A0%E5%88%86%E6%9E%90-toc" style="margin-left:0px;">根因分析

配置

构造

创建 network

构造 zookeeper

kafka-toc" style="margin-left:80px;">构造 kafka

参数构造

原理解析

图解

全过程解析

工具使用

kafkacat-toc" style="margin-left:120px;">kafkacat

查看 broker

python%20%E5%AE%9E%E7%8E%B0-toc" style="margin-left:0px;">python 实现

python%20send%20%2B%20kafka%20recv-toc" style="margin-left:0px;">python send + kafka recv

python%20%E4%BB%A3%E7%A0%81-toc" style="margin-left:80px;">python 代码

kafka%20recv-toc" style="margin-left:80px;">kafka recv

运行效果

python%20recv%20%2B%20kafka%20send-toc" style="margin-left:40px;">python recv + kafka send

python%20%E4%BB%A3%E7%A0%81%C2%A0-toc" style="margin-left:80px;">python 代码 

kafka%20send-toc" style="margin-left:80px;">kafka send

运行效果

思考

python%20send%20%2B%20python%20recv-toc" style="margin-left:40px;">python send + python recv

原理

运行效果

---

背景

如果你已经完整阅读Milvus核心组件（4）---- MinIO 结合 Kafka 的配置，使用及原理（超详细版）-CSDN博客，并动手实际操作过，那么你对minio+kafka的使用已经完全入门。但是有一个问题，你会发现我们的调用机制是 python 调用了 minio 所在的服务，由他关联的 kafka 被调用。但是你在docker 外主机中，通过 python 调用 kafka 会发现会失败。试想你正在做一大大型应用，要求python 写入 minio 之后，联动kafka 自己做一点自己需要完成的事情。这个scope 本身已经超越了 milvus 本身，因为你可能认为在milvus 配置中，你已经完成了minio+kafka 的搭建，并从kafka 中正确收到了minio 关于 bucket 的 event 事件。当然你可以利用这一点，做一些额外的