我试图把gzip数据放入Kafka并读取它。但是，正如我所看到的，input bytearray和output bytearray是不一样的。我很确定gzip格式在生产者方面是正确的（我在提交之前重新检查并打印了值），但是当我从kafka主题中得到这个值时，它说
“java.util.zip.zipexception:不是gzip格式”
我在生产和消费两方面都打印了数据。以及ı 发现它们不一样。
顺便说一下，字符串值可以正常工作。我的序列化程序配置是：

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

是我遗漏了什么，还是有一个配置让它发生？
太多了