kafka producer 压缩

Kafka Producer支持消息压缩功能，可以减少消息的传输大小，提高网络传输效率。Kafka提供了多种压缩算法供选择，包括Gzip、Snappy、LZ4和Zstd。

要在Kafka Producer中启用消息压缩，你可以通过设置消息的compression.type属性来指定所使用的压缩算法。例如，你可以将该属性设置为"gzip"来使用Gzip算法进行压缩。

以下是一个使用Gzip压缩的Kafka Producer示例：

import org.apache.kafka.clients.producer.ProducerConfig;import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.KafkaProducer;

import java.util.Properties;

public class MyKafkaProducer {
    public static void main(String[] args) {
        // 配置Kafka Producer
        Properties props = new Properties();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,