概述
下图展示了 Apache Kafka binder 如何操作的简化示意图:
Apache Kafka Binder 实现将每个目标映射到一个 Apache Kafka 主题。消费者组直接映射到相同的 Apache Kafka 概念。分区也直接映射到 Apache Kafka 分区。
当前 binder 使用的是 Apache Kafka kafka-clients
版本 3.1.0
。该客户端可以与较旧的 broker 进行通信(请参阅 Kafka 文档),但某些功能可能不可用。例如,对于早于 0.11.x.x 的版本,不支持原生头信息。此外,0.11.x.x 不支持 autoAddPartitions
属性。