问Kafka Connect Sink "Passthrough“连接器
EN

Stack Overflow用户

提问于 2019-02-22 01:19:39

回答 2查看 131关注 0票数 0

kafka jdbc接收器连接器是否支持将其消耗的内容写入不同的主题。我正在寻找一个直通机制，如下图所示。如果没有，我可以链接一个接收器和源代码(从接收器写入的地方读取)，但不要认为这会有很好的性能。也许我可以修改现有的接收器连接器来实现这一点？

Topic 1 -> Sink Connector ->  Topic 2
               |
               V
               DB

发布于 2019-02-22 05:12:20

连接框架允许写入导致错误记录的死信队列主题，但连接中没有这样的tee-like功能。

如果你想要一个源从接收器中读取写入的内容，那么你应该有两个连接器。

例如,

JDBC_Sink -> DB -> Debezium -> Topic

票数 0

发布于 2019-02-23 04:25:05

我建议编写一个简单的Kafka Streams应用程序，将topic 1中的所有内容转发到topic 2中，并按原样使用连接器将topic 1中的内容接收到DB中。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/54812799

复制

相似问题

问Kafka Connect Sink "Passthrough“连接器EN