在字符串列上应用转换器以在debezium源代码中执行修剪

alen0pnh  于 2021-06-05  发布在  Kafka
关注(0)|答案(0)|浏览(222)

我有一个源数据库,它用空格填充字段,直到达到字段的大小。例如,如果我们有一张 VARCHAR(20) ,如果我得到这个信息,结果将是大小 20 每次都不需要实际的字段值,而需要完整的大小。
举个例子:如果我们放置一个大小为5的字符串,遗留系统将添加一个结尾带有空格的pad,迫使字段达到列的最大大小。
我的原始数据库是一个sql server,我使用kafka和debezium作为源连接器来获取cdc更改,并将其放入一个接收器连接器,即postgresql中。
存在要作为转换器应用的内容,仅修改字符串以执行 trim() 不用那些多余的空间就可以保存我的主题?
转换需要在Kafka完成。我不能修改原点,因为它是第三方系统,所以转换需要由转换器或连接器完成。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题