编写自定义kafka connect单个消息转换

mzillmmw  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(480)

我在网上搜索了这个问题,读了几篇文章,最后来到这里。我已经配置了kafka connect mongodb接收器,我想通过实现一些定制逻辑来转换消息。kafka connect是否仅限于内置smt(或是否可以编写自定义smt)。如果不是,我怎么能做到这一点?穿过溪流?

nwlls2ji

nwlls2ji1#

Kafka连接是否仅限于内置SMT
不,不是。您可以创建自己的插件并将它们添加到插件路径中
https://www.confluent.io/blog/kafka-connect-single-message-transformation-tutorial-with-examples

相关问题