在Ubuntu上配置Apache Kafka以啟用消息壓縮，可以通過修改Kafka服務器和客戶端的配置文件來實現。以下是啟用壓縮的步驟：
選擇壓縮編解碼器：
Kafka支持多種壓縮編解碼器，如gzip, snappy, lz4, zstd等。選擇一個合適的編解碼器，根據你的需求和性能考慮。
配置Kafka服務器：
打開Kafka服務器的配置文件server.properties，通常位于/etc/kafka/目錄下。
# 啟用壓縮
compression.type=gzip # 或者其他壓縮編解碼器，如snappy, lz4, zstd
# 設置壓縮級別（對于gzip有效）
# 壓縮級別范圍從0（無壓縮）到9（最大壓縮）
# 默認值通常是6
# compression.level=6
配置Kafka生產者： 如果你使用的是Kafka生產者發送消息，可以在生產者的配置文件中設置壓縮編解碼器。如果你是通過編程方式使用Kafka生產者，可以在創建生產者實例時設置。
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("compression.type", "gzip"); // 設置壓縮編解碼器
KafkaProducer<String, String> producer = new KafkaProducer<>(props);
配置Kafka消費者： 消費者通常不需要特別配置來解壓縮消息，因為Kafka客戶端庫會自動處理解壓縮。但是，確保你的消費者配置正確，以便能夠連接到Kafka集群并讀取消息。
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
重啟Kafka服務器： 修改配置文件后，重啟Kafka服務器以使更改生效。
sudo systemctl restart kafka
驗證壓縮是否啟用： 你可以通過發送消息并檢查消息大小來驗證壓縮是否啟用。如果消息大小明顯減小，那么壓縮已經成功啟用。
請注意，啟用壓縮可能會增加CPU的使用率，因為壓縮和解壓縮操作需要計算資源。因此，在啟用壓縮之前，請確保你的系統有足夠的資源來處理這些額外的負載。
