Kafka配置消息保存时间的方法

Kafka配置消息保存时间可以通过两种方式实现：

1. 通过配置文件配置

在Kafka的配置文件中，可以通过以下两个参数来配置消息保存时间：

log.retention.ms=86400000
log.retention.hours=24

其中，log.retention.ms表示消息保存时间的毫秒数，log.retention.hours表示消息保存时间的小时数。这里的例子中，都表示保存一天的消息。

2. 通过API配置

Kafka提供了API来配置消息保存时间，可以通过以下代码实现：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
AdminClient adminClient = AdminClient.create(props);
Map<ConfigResource, Config> configs = new HashMap<>();
ConfigResource cr = new ConfigResource(ConfigResource.Type.TOPIC, "test");
Config config = new Config(Arrays.asList(new ConfigEntry("retention.ms", "86400000")));
configs.put(cr, config);
AlterConfigsResult alterConfigsResult = adminClient.alterConfigs(configs);

这里的例子中，使用AdminClient来修改"test"主题的消息保存时间为一天。