Help- issues with Transforms connect

Kafka Connect
1

Hello everyone,
I need your help because I don’t find a solution.
My goal is to go to : text_LASTNAME_FIRSTNAME

My config :
> “transforms”: “createKey, extractString, dropPrefix”,

    "transforms.createKey.type": "org.apache.kafka.connect.transforms.ValueToKey",
    "transforms.createKey.fields": "LASTNAME",
    "transforms.extractString.type":"org.apache.kafka.connect.transforms.ExtractField$Key",
    "transforms.extractString.field":"LASTNAME",
    "transforms.dropPrefix.type": "org.apache.kafka.connect.transforms.RegexRouter",
    "transforms.dropPrefix.regex": "*_json",
    "transforms.dropPrefix.replacement": "text_${LASTNAME}",

My message:

[
{
“topic”: “********_json”,
“partition”: 0,
“offset”: 0,
“key”: “TESTEST”,
“value”: {
“LOCALSTART”: “2021-08-21 05:48:20:00”,
“LOCALEND”: “2021-08-21 05:50:00:00”,
“LASTNAME”: “plip”,
“FIRSTNAME”: “plop”,

},
"__confluent_index": 0

}
]

Thank you everyone…

2

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