我的应用程序是使用Sping Boot 在Java中实现的。我们使用Kafka来接收来自另一个在.net中实现的应用程序的消息。当消息大小大于1MB时，从生产者端开始，他们已经实现了压缩。但压缩后，消息以字节格式发送，在消费者端，我们得到“消息转换异常”。
我们是否需要解压缩以字节为单位的消息？我尝试搜索，但我没有找到任何解压缩技术在消费者端使用Java Sping Boot 。有没有人遇到过这种情况？
先谢谢你。