serialization - Kafka gzip values are getting corrupted inside topic -


i trying put gzip data kafka , read it. , have seen, input bytearray , output bytearray not same. pretty sure gzip format right on producer side(i rechecked , printed values before submission) when value kafka topic, says

"java.util.zip.zipexception: not in gzip format"

i printed data in both producerand consumer side. , ı have found not same.

string values working without problem way. , serializer config is:

key.serializer=org.apache.kafka.common.serialization.bytearrayserializer value.serializer=org.apache.kafka.common.serialization.bytearrayserializer 

am missing or there configuration make happen?

thx lot


Comments