The following provides usage information for the Confluent SMT io.confluent.connect.transforms.GzipDecompress.


GzipDecompress is not currently available for managed connectors.


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.


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.dropPrefix.type": "io.confluent.connect.transforms.GzipDecompress"

base64-conversion=$(echo “Hello world” | base64 ) -> SGVsbG8gd29ybGQK gzipped-conversion=$(echo “Hello world” | base64 | gzip )

Before: gzipped-conversion

After: base64-conversion


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 Filter (Apache Kafka), predicates can conditionally filter out specific records. For details and examples, see Predicates.