How to use Kafka SMT to modify topic key created by couchbase source connector

Kafka Connector
1

I’m trying to use the SMT functions to replace the UUID message key the couchbase source connector generates with a field from within the message. This is what I’ve placed in the properties file for the connector:
‘’’
“transforms”: “ValueToKey, extractKey”,
“transforms.ValueToKey.type”:“org.apache.kafka.connect.transforms.ValueToKey”,
“transforms.ValueToKey.fields”:“UserID”,
“transforms.extractKey.type”:“org.apache.kafka.connect.transforms.ExtractField$Key”,
“transforms.extractKey.field”:“UserId”
‘’’
but so far this seems to do nothing. I tried to pattern the above from this doc: ExtractField | Confluent Documentation

1 Like