如何在Kafka Connect中克隆字段

Question

我正在配置Kafka Connect将数据从Kafka复制到数据库

我需要将某个字段中的值放入数据库中的两列中。

我的Kafka消息有两个字段name和age。目标表有3列name、displayName和age。我想从Kafka消息中克隆name的值，将其放在name和displayName列中。

有没有任何变换，可以通过应用来实现？

Answer 1

正如Driss Nejjar所说，这通常是单消息转换的完美选择。然而，我看不出Apache Kafka附带的Transform可以做到这一点。你可以自己写，也可以使用KSQL:

CREATE STREAM new AS SELECT name, name as displayName, age FROM source;

这将占用您的source主题(由Connect填充)，并添加额外的字段displayName，然后写入一个名为new的新Kafka主题。

免责声明：我为Confluent公司工作，该公司是KSQL项目的幕后推手