Spring Kafka JDBC 连接器兼容性

Question

Kafka JDBC 连接是否与Spring-Kafka 库兼容？

我确实关注了https://www.confluent.io/blog/kafka-connect-deep-dive-jdbc-source-connector/，但仍然有些困惑。

Answer 1

假设您想从 Kafka 主题消费并写入 JDBC 数据库。您的一些选择是

• 使用普通的 Kafka 消费者从主题中消费，并使用 Jdbc api 将消费的记录写入数据库。
• 使用 spring Kafka 从 Kafka Topic 消费和 spring jdbc 模板或 spring 数据将其写入数据库
• 使用带有 Jdbc 连接器的 Kafka 连接作为接收器来读取主题并写入表。

如你所见

• Kafka Jdbc 连接器是一个专用组件，只能完成一项工作。
• Kafka Consumer 是非常通用的组件，它可以完成很多工作，您将编写大量代码。事实上，它将成为其他框架构建和专门化的基础 API。
• Spring Kafka 简化了它，让您将 kafka 记录作为 java 对象处理，但没有告诉您如何将该对象写入您的数据库。

因此，它们是完成任务的替代解决方案。话虽如此，您可能有一个流程，其中不同的段由不同的团队控制，对于每个段，可以使用其中任何一个，Kafka 主题将充当加入通道