Hello, I really wonder that whether i can stream compressed data with using KafkaUtils.createDirectStream(...) or not.
This is formal code that i use ; JavaPairInputDStream<String, String> messages = KafkaUtils.createStream(javaStreamingContext, zookeeperConfiguration, groupName, topicMap, StorageLevel.MEMORY_AND_DISK_SER()); in this code i am consuming string message but in my case i need to consume compressed data from stream then uncompress it. Could you please asist me how i can go in right way ? -- bhayat
