概述

下图显示了 Apache Kafka 绑定器如何工作的简化图

Apache Kafka 绑定器实现将每个目标映射到 Apache Kafka 主题。消费者组直接映射到相同的 Apache Kafka 概念。分区也直接映射到 Apache Kafka 分区。

绑定器目前使用 Apache Kafka kafka-clients 版本 3.1.0。此客户端可以与旧的代理通信(参见 Kafka 文档),但某些功能可能不可用。例如,在 0.11.x.x 之前的版本中,不支持原生标头。此外,0.11.x.x 不支持 autoAddPartitions 属性。