aru*_*nan 3 apache-kafka apache-kafka-connect
我已经配置了一个 kafka 连接 Mongodb 接收器，我想通过实现一些自定义逻辑来转换消息。
Kafka connect 是否仅限于内置 SMT（或者）是否可以编写自定义 SMT。如果不是，我怎样才能实现这一目标？通过溪流？
\n\nKafka connect 是否仅限于内置 SMT
\n
不它不是。您可以创建自己的并将它们添加到您的插件路径中
\n\n\n转换被编译为 JAR，并通过 Connect worker\xe2\x80\x99s 属性文件中指定的plugin.path 提供给 Kafka Connect。安装后，可以在连接器属性中配置转换。
\n
https://www.confluence.io/blog/kafka-connect-single-message-transformation-tutorial-with-examples
\n示例仓库https://github.com/confluenceinc/kafka-connect-insert-uuid
\n或者我自己的https://github.com/OneCricketeer/schema-registry-transfer-smt
\n| 归档时间： |
|
| 查看次数： |
8922 次 |
| 最近记录： |