Kafka Connect GzipDecompress SMT Usage Reference for Confluent Platform¶
The following provides usage information for the Confluent SMT io.confluent.connect.transforms.GzipDecompress
.
Caution
GzipDecompress is not currently available for managed connectors.
Description¶
Gzip-decompresses the byteArray input that was Gzip compressed. The SMT can only work with ByteArray format input.
Under the hood, the input is decompressed using java.util.zip.GZIPInputStream
, and returns resultant ByteArray output.
Installation¶
This transformation is developed by Confluent and does not ship by default with Apache Kafka® or Confluent Platform. You can install this transformation using the confluent connect plugin install command:
confluent connect plugin install confluentinc/connect-transforms:latest
Examples¶
The following examples show how to configure and use GzipDecompress
.
Gzip-decompress a base64 input¶
This configuration snippet shows how to decompress a gzip-compressed base64 input.
"transforms": "gzipDecompress",
"transforms.gzipDecompress.type": "io.confluent.connect.transforms.GzipDecompress$Value"
base64-conversion=$(echo “Hello world” | base64 ) -> SGVsbG8gd29ybGQK gzipped-conversion=$(echo “Hello world” | base64 | gzip )
Before: gzipped-conversion
After: base64-conversion
Predicates¶
Transformations can be configured with predicates so that the transformation is applied only to records which satisfy a condition. You can use predicates in a transformation chain and, when combined with the Kafka Connect Filter (Kafka) SMT Usage Reference for Confluent Platform, predicates can conditionally filter out specific records. For details and examples, see Predicates.