我在生产者端启用了快速压缩，并进行了以下更改：
props.put(ProducerConfig.COMPRESSION_TYPE_CONFIG,"snappy");
现在，消费者方面是否需要对此进行任何更改？我检查了 Consumer.config，但在那里没有找到任何compression_type参数。
当我运行时，代码消息没有进入消费者端，我收到以下错误：
[1/10/20 17:25:39:759 UTC] 00018027 org.apache.kafka.clients.consumer.KafkaConsumer I [Consumer clientId=com.ora.def.lieo, groupId=group-cedm] Seeking to offset 320 for partition Party-Resolved-Check-0
[1/10/20 17:25:49:760 UTC] 00018029 com.ibm.cedm.kafka.KafkaConsumerService E Received exception when fetching the next record from Party-Resolved-Check-0. If needed, please seek past the record to continue consumption.
不需要解压缩配置。使用者会自动处理此问题。
不清楚您的错误与压缩有何关系