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
}
}