在kafka连接源连接器中使用消息键

ttvkxqim 于 2021-06-08 发布在 Kafka

关注(0)|答案(1)|浏览(310)

我正在使用kafka connect jdbc源连接器从数据库中的视图中读取数据并将其发布到kafka上，它工作正常。
我的用例是，用户可以创建多个对象，对象的顺序在我的应用程序中很重要。我想使用用户id作为我发布到主题中的所有消息的消息键来维护它们的顺序。
我的问题是如何在kafka connect源连接器中定义消息键？

apache-kafka apache-kafka-connect

来源：https://stackoverflow.com/questions/50978221/use-message-key-in-kafka-connect-source-connector

1条答案

按热度按时间

5ktev3wc1#

您可以通过添加以下代码来连接文件源配置文件，从而使用kafka connect的smt（单消息转换）功能。

transforms=createKey
transforms.createKey.type=org.apache.kafka.connect.transforms.ValueToKey
transforms.createKey.fields=UserId <name of user id column>

有关smt的更多信息，请点击此处

赞(0）回复(0）举报 2021-06-08

我来回答

在kafka连接源连接器中使用消息键

1条答案

相关问题

热门标签

最新问答