时间戳

首页 > 解决方案 > Spring Kafka JDBC 连接器兼容性

spring-boot - Spring Kafka JDBC 连接器兼容性

问题描述

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

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

标签： spring-bootspring-kafkaapache-kafka-connectconfluent-platform

解决方案

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

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

如您所见

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

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

推荐阅读