一、 Kafka支持的消息压缩类型

Kafka支持许多种消息压缩类型，包括：

• gzip
• snappy
• lz4
• zstd

二、啥是Kafka的消息压缩

消息压缩是指将消息数据以压缩格式存储和传输，从而少许些存储地方和网络传输数据量。在Kafka中，消息压缩实现，如GZIP、Snappy、LZ4或ZSTD。

三、 消息压缩类型啥时候需要

以下情况兴许需要启用消息压缩：

• 少许些磁盘存储需求
• 少许些网络传输数据量
• 搞优良Kafka性能

四、怎么开启压缩

1. 在Broker端开启压缩

要设置消息压缩，能在Kafka broker的配置文件中添加或修改以下行：

compression.type=snappy

这玩意儿属性用于设置服务器端默认的压缩类型。您能设置为上述编解码器之一， 或者设置为producer这样Kafka会根据生产者设置的压缩类型来压缩消息。

2. 在生产者端开启压缩

在生产者的配置文件中，您需要设置以下属性来指定压缩类型：

compression.type=gzip

这行代码将设置生产者发送消息时用的压缩类型为gzip。

3. 在消费者端开启压缩

消费者通常不需要特别的配置来处理压缩消息，基本上原因是Kafka会自动解压缩接收到的消息。但是确保消费者的配置与生产者的配置兼容是很关键的。

五、 配置Kafka服务器

打开Kafka服务器的配置文件，您需要设置以下属性：

• compression.type设置消息压缩类型。
• log4j.properties配置日志记录相关属性。

完成配置后 用以下命令沉启Kafka服务以使更改生效：

sudo systemctl restart kafka

六、验证压缩

您能通过Kafka的控制台生产者或用Kafka工具来发送和接收消息，并检查消息是不是已被正确压缩和优良压缩。

。

---