有预定义的kafka connect smt,它们以链式方式工作,但是有没有一种方法可以编写自定义smt?我的目标是从列(extractfield smt)中提取一个值。这个字段将是一个数字字段,然后在链中,我想获取提取的数值的最后一位。这个数值将是kafka中发送消息的分区号。我无法找出如何提取所提取字段的最后一个数字。
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!