kafka jdbc接收器连接器是否支持将其消耗的内容写入不同的主题。我正在寻找一个直通机制,如下图所示。如果没有,我可以链接一个接收器和源代码(从接收器写入的地方读取),但不要认为这会有很好的性能。也许我可以修改现有的接收器连接器来实现这一点?
Topic 1 -> Sink Connector -> Topic 2
|
V
DB
发布于 2019-02-22 05:12:20
连接框架允许写入导致错误记录的死信队列主题,但连接中没有这样的tee
-like功能。
如果你想要一个源从接收器中读取写入的内容,那么你应该有两个连接器。
例如,
JDBC_Sink -> DB -> Debezium -> Topic
发布于 2019-02-23 04:25:05
我建议编写一个简单的Kafka Streams应用程序,将topic 1中的所有内容转发到topic 2中,并按原样使用连接器将topic 1中的内容接收到DB中。
https://stackoverflow.com/questions/54812799
复制相似问题