ValueToKey

Description

Replace the record key with a new key formed from a subset of fields in the record value.

You can configure Java streams applications to deserialize and ingest data in multiple ways, including Kafka console producers, JDBC source connectors, and Java client producers. For full code examples, see connect-streams-pipeline.

Properties

Name Description Type Default Valid Values Importance
fields Field names on the record value to extract as the record key. list   non-empty list high