我需要在不同的数据库上使用两个完全相同的表(位置也不同)才能在同一主题上发布。Kafka JDBC连接器没有解释它是如何管理高水印的,所以我们想检查一下这个场景中的最佳实践是什么? 1.我们是否可以将两个单独的JDBC连接器发布到单独的主题2。我们是否可以保持两个单独的JDBC连接器发布到同一个主题。
如果我们选择选项2,那么Kafka连接器是如何在消息同时到达表的情况下管理的呢?如何管理不同的数据库时区?
发布于 2020-04-06 16:51:26
?
是。
是
卡夫卡JDBC连接器是如何在消息同时到达表的情况下管理的?
您将得到关于目标主题的两条消息。如果有的话,你的消费者需要逻辑来处理重复。您可以使用单个消息转换来设置写入主题的消息的键,并将其用作去复制的一部分。
https://stackoverflow.com/questions/61063891
复制相似问题