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
Post a Comment