apache-kafka - Kafka 单消息转换以用另一个子字符串替换子字符串

Question

我正在使用源连接器，并且想用另一个子字符串替换特定 JSON 属性的子字符串。替换将针对特定主题的所有消息。

是否可以使用“单个消息转换”将一个字符串替换为另一个字符串？

非常感谢您的意见

标签： apache-kafka

Answer 1

Connect 是开源框架，因此您可以添加任何您想要的逻辑

是的，有可能，但是，您可能必须编写自己的 Transform 实现来执行此操作。