How to decompress gzip messages from a Kafka source in Flume

Asked May 10 '19 at 17:46

Active May 11 '19 at 16:10

Viewed 260 times

I have a Flume agent with morphline interceptor that reads from a Kafka source with messages compressed in gzip.

Anyone knows how to decompress these messages before morphline process it?

Thanks!!

edited May 11 '19 at 16:10

asked May 10 '19 at 17:46

Possible duplicate of [compression and decompression of string data in java](https://stackoverflow.com/questions/16351668/compression-and-decompression-of-string-data-in-java) – Manoj Vadehra May 10 '19 at 18:05
Morphline Interceptor is not written in Java. – Alejandro Sánchez Muñoz May 11 '19 at 16:11

0 Answers0