Debezium 消息与 kafka-connect sink 连接器期望的格式兼容答案

【问题标题】：Debezium message compatible with format that kafka-connect sink connectors expectDebezium 消息与 kafka-connect sink 连接器期望的格式兼容
【发布时间】：2022-01-10 05:44:11
【问题描述】：

我有一个debezium 实例，它跟踪postgres 上的更改并将更改消息发送到kafka。在kafka 的另一边，我有kafka connect 和amazon redshift sink connector，并且连接器期望的消息格式与debezium 发送到kafka 的消息格式不兼容。有什么办法可以强制debezium发送amazon redshift sink connector可以接受的消息？

【问题讨论】：

标签： apache-kafka apache-kafka-connect debezium

【解决方案1】：

解决方案是在source 或sink 连接器端使用New Record State Extraction SMT。

【讨论】：