Sink connector - Add key in separate column

Kafka Connect
1

Hello!
In kafka I have a message with key “id”
How can I add this key to a separate column when setting up the sink connector

{
“schema”:{
“type”:“struct”
“fields”:[
0:{
“type”:“int32”
“optional”:false
“field”:“id”
}
]
“optional”:false
“name”:“ba_update_test.public.update_test.Key”
}
“payload”:{
“id”:2
}
}

2

Is that the value schema? Have you tried using the ValueToKey transform with fields set to id?

And not clear what connector you’re using, but JDBC sink can already write keys to columns

3

I solved this case.
I used Custom transform based InsertField transform and added new type record.key().toString()

4

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.