Static Message Key JDBC Source Connector

Kafka Connect
1

Hi,

is it possible to set a static message key?
I only see an example for a dynamic message key like this;

"transforms":"createKey,extractInt",
"transforms.createKey.type":"org.apache.kafka.connect.transforms.ValueToKey",
"transforms.createKey.fields":"id",
"transforms.extractInt.type":"org.apache.kafka.connect.transforms.ExtractField$Key",
"transforms.extractInt.field":"id"

I only want that:

"transforms":"createKey",
"transforms.createKey.type":"org.apache.kafka.connect.transforms.ValueToKey",
"transforms.createKey.fields":"SaticKeyValue",

Tahnks for help.

Regards,

Marcel

2

I think you can use org.apache.kafka.connect.transforms.InsertField$Key to do this.

Just a thought, if you’re setting the same key for every single message though is there much point?

3

Ok, that is what i am looking for thx Robin.

4

@rmoff
Hi Robin maybe you can help me again.
I try this:

"transforms.insertKey.type": "org.apache.kafka.connect.transforms.InsertField$Key",
"transforms.insertKey.static.field": "MessageSource",
"transforms.insertKey.static.value": "Database"

But the message Key is still null. Any Ideas?