在MongoDB Kafka连接器中添加头信息

Question

我使用以下连接器从MongoDB获取数据到我的Kafka主题:

{
"class": "com.mongodb.kafka.connect.MongoSourceConnector",
"type": "source",
"version": "1.10.0"
}

并且来到Kafka主题的记录具有空头信息:

headers: {}

我这里需要的是在连接器中添加硬编码的标头信息，以便连接器处理的所有记录都可以具有类似于

的标头:

headers: {"Source": "MongoDB"}

我遇到了一个名为InsertHeader: https://docs.confluent.io/platform/current/connect/transforms/insertheader.html#insertheader的转换，它似乎正是我需要的，但是，当我试图将它与连接器一起使用时，它抛出了错误:

Invalid value org.apache.kafka.connect.transforms.InsertHeader for configuration transforms.InsertHeader.type: Class org.apache.kafka.connect.transforms.InsertHeader could not be found.

声明InsertHeader目前不可用于托管连接器这就是它不能使用的原因吗?

我可以使用哪些替代方案?

提前谢谢你。

Answer 1

当您说"托管连接器"时，我认为您指的是Confluent Cloud。

在这种情况下，您需要自我管理以控制任何连接器可以使用的插件/转换

或者，不进行转换的部署。使用其他工具来使用和插入标头，并写入新主题