apache-kafka - 卡夫卡生产者与卡夫卡连接器

Question

我需要通过调用存储过程将数据从数据库（比如 Oracle DB）推送到 kafka 主题。我也需要对消息进行一些验证

我应该使用生产者 API 还是 Kafka 连接器。

标签： apache-kafkaspring-kafkaapache-kafka-connect

Answer 1

您应该使用 Kafka Connect。要么，要么使用生产者 API 并编写一些代码来处理：

• 向外扩展
• 故障转移
• 重启
• 模式
• 序列化
• 转型

并以标准化方式与数百种其他技术集成，便于移植和管理。

到那时，您将彻底改造 Kafka Connect ;-)

要了解有关 Kafka Connect 的更多信息，请参阅此演讲。要了解数据库->Kafka 摄取的细节，请参阅此演讲和此博客。