The following provides usage information for the Confluent SMT
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
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 )
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.