在Kafka连接源连接器中使用消息密钥

提问于 2024-05-04T10:45:42+08:00

浏览次

1

我正在使用Kafka连接JDBC源连接器从数据库中的视图读取并将其发布到kafka上，它工作正常 .

我的用例是用户可以创建多个对象，对象的顺序在我的应用程序中很重要 . 我想使用用户ID作为我发布到主题中的所有消息的消息密钥来维护他们的订单 .

我的问题是如何在Kafka连接源连接器中定义消息密钥？

1 回答

2
您可以通过向connect-file-source配置文件添加以下代码来使用Kafka Connect的SMT（单消息转换）功能 .
```
transforms=createKey
transforms.createKey.type=org.apache.kafka.connect.transforms.ValueToKey
transforms.createKey.fields=UserId <name of user id column>
```
有关SMT here的更多信息
回复于 2024-05-04T10:45:42+08:00

相关问题