{"repo":"Aiven-Open/transforms-for-apache-kafka-connect","free":true,"listed":false,"github":"https://github.com/Aiven-Open/transforms-for-apache-kafka-connect","clone":"git clone https://github.com/Aiven-Open/transforms-for-apache-kafka-connect.git","description":"Aiven's collection of Single Message Transformations (SMTs) for Apache Kafka Connect","language":"Java","stars":89,"topics":["kafka","kafka-connect","kafka-connect-transformations","kafka-connect-transforms"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"Aiven Transformations for Apache Kafka® Connect A collection of Single Message Transformations (SMTs) for Apache Kafka Connect. Transformations See the Kafka documentation for more details about configuring transformations or demo on how to install transforms. ExtractTimestamp This transformation replaces the original record's timestamp with a value taken from the the record. The transformation: - expects the record value to be either a STRUCT or a MAP ; - expects it to have a specified field; - expects the value of the field to be either INT64 or org.apache.kafka.connect.data.Timestamp and not be null . Exists in two variants: - io.aiven.kafka.connect.transforms.ExtractTimestamp$Key - works on keys; - io.aiven.kafka.connect.transforms.ExtractTimestamp$Value - works on values. The transformation defines the following configurations: - field.name - The name of the field which should be used as the new timestamp. Cannot be null or empty. - timestamp.resolution - The timestamp resolution for key or value There are two possible values: - milliseconds - key or value timestamp in milliseconds - seconds - key or value timestamp in seconds and will be converted in milliseconds, the default is milliseconds . Here's an example of this transformation configuration: ExtractTopic This transformation extracts a string value from the record and use it as the topic name. The transformation can use either the whole key or value (in this case, it must have INT8 , INT16 , INT32 , INT64 , FLOAT3","default_branch":null,"files":null,"tree":[],"storefront":"/r/Aiven-Open","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/Aiven-Open/transforms-for-apache-kafka-connect/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}