Kafka系列之:自定义转换Transformation
如果可用的单一消息转换 (SMT) 均未提供必要的转换,可以创建自己的转换。首先要理解的一个重要概念是,通常,SMT 实现在抽象类中提供大部分逻辑。SMT 实现然后提供两个具体的子类,称为 Key 和 Value,它们指定是处理 Connect 记录的键还是值。使用转换时,用户指定 Key 或 Va
如果可用的单一消息转换 (SMT) 均未提供必要的转换,可以创建自己的转换。首先要理解的一个重要概念是,通常,SMT 实现在抽象类中提供大部分逻辑。SMT 实现然后提供两个具体的子类,称为 Key 和 Value,它们指定是处理 Connect 记录的键还是值。使用转换时,用户指定 Key 或 Va