我正在配置kafka connect将数据从kafka复制到数据库我需要把某个字段的值放到数据库的两列中。我的Kafka消息有两个字段 name , age . 目标表有3列 name , displayName 以及 age . 我想克隆 name 从Kafka的信息，把它放在两列 name 以及 displayName .有没有什么变换可以用来做这个？
name
age
displayName
bmvo0sr51#
正如driss-nejjar所说，这通常是一个消息转换最适合的类型。但是，我看不到apachekafka附带的任何转换可以做到这一点。您可以自己编写，也可以使用ksql：
CREATE STREAM new AS SELECT name, name as displayName, age FROM source;
这会占用你的时间 source 主题（由connect填充），并添加附加字段 displayName ，写一个新的Kafka主题，叫做 new .免责声明：我在confluent工作，这是一家支持ksql项目的公司。
source
new
1条答案
按热度按时间bmvo0sr51#
正如driss-nejjar所说，这通常是一个消息转换最适合的类型。但是，我看不到apachekafka附带的任何转换可以做到这一点。您可以自己编写，也可以使用ksql：
这会占用你的时间
source主题（由connect填充），并添加附加字段displayName，写一个新的Kafka主题，叫做new.免责声明：我在confluent工作，这是一家支持ksql项目的公司。