如何启用Kafka接收器连接器以便在接收器启动时将主题中的数据插入到表中

问题描述 投票:0回答:1

我为我的数据存储(Amppol AD​​S)开发了kafka-sink-connector(使用confluent-oss-3.2.0-2.11,连接框架),它将来自kafka主题的数据存储到我商店中的相应表中。

只要kafka服务器和ADS服务器启动并运行,每件事都按预期工作。

需要有关特定用例的帮助/建议,其中事件在kafka主题中被摄取并且接收器组件(ADS)下面已关闭。这里的期望是每当一个接收服务器出现时,应该将早先在kafka主题中提取的记录插入到表中;

请告知如何处理此类案件。

在这个连接框架中是否有任何支持..?或至少一些参考将是一个很大的帮助。

apache-kafka apache-kafka-connect confluent
1个回答
© www.soinside.com 2019 - 2024. All rights reserved.