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!!
Linked Questions
- Is Kafka ready for production use?
- Missing messages on Kafka's compacted topic
- How to find the root cause of high CPU usage of Kafka brokers?
- Does Kafka support secure communication?
- Apache kafka: Failed to acquire lock on file .lock in tmp/kafka-logs
- Kafka - mirror from one server to another server
- Kafka consumer start with latest
- Kafka console consumer: How to get only the last N messages from a topic instead of everything from the beginning?
- How much memory Kafka cluster needs?
- installing zookeeper telnet gives error
- Migrate Zookeeper Offset details to Kafka
- Why is Kafka pull-based instead of push-based?
- Using Kafka for multicasting between clients
- Delete topic in Kafka 0.8.1.1
- The type initializer for 'RdKafka.Internal.LibRdKafka' threw an exception
Popular Questions
- Can't change log level at runtime (log4j2)
- CGImageCreate: invalid image size: 0 x 0
- Partially applied generic function "cannot be cast to Nothing"
- Peek and Pop not an option
- RTSP Client Connected to VLC
- Get nodes of specific type in Networkx
- "bower install" failing on jenkins, but runs well through command line
- Google Developers Console - Duplicate Fingerprint
- How to parse custom objects from a list within a jsonstring?
- PHP Trait colliding constructor
0 Answers
Related Questions
- Implement custom partitioner in kafka .net
- Create multiple consumer group for multiple topic
- kafka consumer rebalancing in case of manual/assigned partitioning
- Apache KAFKA and supported platforms
- How to retrieve a specific count of messages from Kafka Topic
- Trouble with kafka example
- Partition re-balance on brokers in Kafka 0.8
- Simple-Kafka-consumer message delivery duplication
- Data Modeling with Kafka? Topics and Partitions
- Is there any workaround for simpleConsumer module to read only the new messages?
- Apache Kafka Consumer group and Simple Consumer
- Why does server fail with "java.net.SocketException: invalid argument" upon server's startup?
- KafKa partitioner class, assign message to partition within topic using key
- Kafka 0.8, is it possible to create topic with partition and replication using java code?
- Apache Kafka Default Encoder Not Working