用途：面向 Apache Kafka、事件流、Kafka Streams 及事件驱动架构的专家级指导，适用于用户提及流式、消息、事件驱动或 Kafka 的场景。
主要能力：覆盖核心概念，包括主题、分区与偏移量、生产者与消费者、消费者组、Kafka Streams、Kafka Connect 以及 Exactly-once 语义；并给出生产者与消费者代码示例（Python kafka 客户端）、Kafka Streams 示例（Java），以及最佳实践与反模式清单。
使用方式：资料以代码示例展示典型用法，例如生产者以 bootstrap_servers=['localhost:9092'] 连接、acks='all'、retries=3，发送 'user-events' 消息并通过 future.get(timeout=10) 获取元数据，最后 flush 与 close；消费者使用 group_id、auto_offset_reset='earliest'、enable_auto_commit=False，并在处理后手动 consumer.commit()；Kafka Streams 通过 StreamsConfig 设置 APPLICATION_ID_CONFIG 与 BOOTSTRAP_SERVERS_CONFIG，用 StreamsBuilder 读取 input-topic，经 filter 与 mapValues 转换后写入 output-topic。
最佳实践：使用合适的分区键、监控消费者延迟、实现幂等生产者、用消费者组实现扩展、设置合适保留策略、优雅处理再均衡、监控集群指标。反模式：单分区主题、无错误处理、忽略消费者延迟、向错误分区生产、不使用消费者组、同步处理、缺乏监控。
限制：资料未提供具体版本兼容性、性能基准、收费或定价信息，也未提供部署步骤与平台要求，这些内容暂未提供。