在Ubuntu上配置apache kafka的消息保留策略，可以通過修改kafka的配置文件server.properties來實現。以下是詳細的步驟：
1. 找到并編輯server.properties文件
首先，你需要找到kafka的配置文件server.properties。這個文件通常位于Kafka安裝目錄的config文件夾中。例如，如果你的Kafka安裝在/opt/kafka目錄下，那么配置文件路徑可能是：
/opt/kafka/config/server.properties
使用文本編輯器打開這個文件：
sudo nano /opt/kafka/config/server.properties
2. 配置消息保留策略
在server.properties文件中，你可以找到多個與消息保留相關的配置項。以下是一些常用的配置項及其說明：
- log.retention.hours: 設置消息保留的最大小時數。默認值是168小時（一周）。
- log.retention.bytes: 設置每個分區的最大保留字節數。默認值是1073741824字節（1GB）。
- log.segment.bytes: 設置每個日志段的最大字節數。默認值是1073741824字節（1GB）。
- log.segment.ms: 設置日志段的最大存活時間。默認值是604800000毫秒（一周）。
例如，如果你想將消息保留時間設置為30天，可以將log.retention.hours設置為720小時：
log.retention.hours=720
如果你想將每個分區的最大保留字節數設置為2GB，可以將log.retention.bytes設置為2147483648字節：
log.retention.bytes=2147483648
3. 保存并關閉文件
編輯完成后，保存并關閉server.properties文件。
4. 重啟Kafka服務器
為了使配置生效，你需要重啟Kafka服務器。你可以使用以下命令來停止和啟動Kafka服務器：
# 停止Kafka服務器 sudo systemctl stop kafka # 啟動Kafka服務器 sudo systemctl start kafka
或者，如果你使用的是Kafka的啟動腳本，可以使用以下命令：
# 停止Kafka服務器 /opt/kafka/bin/kafka-server-stop.sh # 啟動Kafka服務器 /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
5. 驗證配置
你可以通過Kafka的命令行工具來驗證配置是否生效。例如，使用kafka-consumer-groups.sh腳本查看消費者組的詳細信息：
/opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group your-consumer-group
通過查看輸出信息，你可以確認消息保留策略是否已經生效。
