用途：在 Kubernetes 上部署与使用 Apache Kafka，基于 Strimzi operator 与 KRaft 模式（不使用 ZooKeeper），并辅助分析同步架构耦合、设计事件与调试问题。
主要能力：检测目标环境内存并自适应资源配置（<12GB 最小、12-24GB 标准、>24GB 生产）；用 Helm 安装 Strimzi operator，用 kubectl 部署 Kafka 集群与 KafkaTopic CRD；提供 confluent-kafka-python 生产者模板与 FastAPI 用的 AIOConsumer；提供消费者延迟、主题列表与描述等调试命令；分析时间、可用性与行为耦合，讲解最终一致性、领域事件、CloudEvents、Avro schema；覆盖投递语义（至多一次 acks=0、至少一次 acks=all+手动提交、精确一次事务）。
使用方式：快速命令为 make install、make test、make status、make uninstall。安装 operator：helm repo add strimzi https://strimzi.io/charts 后 helm install strimzi-operator strimzi/strimzi-kafka-operator -n kafka --create-namespace --wait。部署集群：kubectl apply -f manifests/kafka-cluster.yaml -n kafka，再 kubectl wait kafka/dev-cluster --for=condition=Ready --timeout=300s -n kafka。创建主题：kubectl apply -f manifests/kafka-topic.yaml -n kafka。验证：kubectl get kafka,kafkatopic,pods -n kafka。本地连接用 localhost:30092，同命名空间用 dev-cluster-kafka-bootstrap:9092。
适用场景：Kubernetes 上的事件流部署、微服务解耦、AI 智能体协调、事务性 outbox 与 Debezium CDC、监控告警。
限制：不部署 ZooKeeper（仅 KRaft）；不管理 Kafka Streams 应用；不配置多数据中心复制。要求 Kubernetes 集群与 Helm 3+，版本为 Strimzi 0.49+、Kafka 4.1.1。资源不足时可能不稳定。