在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
通过查看输出信息，你可以确认消息保留策略是否已经生效。
