S3接收器连接器配置基于Debezium消息的操作类型
我们希望根据操作类型区分Kafka（来自Debezium）中的消息。 我们正在寻找基于Kafka操作类型的路由消息。
Debezium发送不同类型的操作类型，例如R（read），U（UPDATE），DELETE（D）等。
的东西
- 类似于操作= r-＆gt之类 发送到存储桶1
- ；如果操作= u，d - ＆gt; ；发送到Bucket 2
我们想从Debezium隔离快照和Delta数据。
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
您可以使用基于内容的路由器如此示例将操作发送到不同的主题（这需要安装Debezium脚本，请参见同一链接）。这将与消息创建单独的主题，但我不知道您是否可以使用相同的S3接收器连接器将两个主题都带到不同的存储桶中（如似乎它不支持路由），所以您可能可以必须为每个主题创建一个连接器，并使用正确的水槽存储桶配置每个主题。
You can use the Content-Based router as in this example to send the operations to different topics (this requires installing Debezium scripting, see in the same link). This will create separate topics with the messages but I don't know if you can use the same S3 sink connector to take both topics to different buckets (as it seems that it doesn't support routing) so you might have to create a connector for each topic and configure each of them with the correct sink bucket.