Kafka中的时间基准日志压缩是基于墙钟时间，事件时间，还是两者的混合？

Kafka中的时间基准日志压缩机制是基于消息的时间戳实现的。Kafka中消息可以包含时间戳，这个时间戳可以表示消息产生的时间（Event time），也可以表示消息被写入Kafka的时间（Wall clock time）或者其他时间。具体来说，Kafka中的log.cleaner.min.cleanable.dirty.ratio参数指定了一个因子，当未压缩消费的消息超过了该因子与该分区中的最大偏移量间的距离时，就会触发该分区的日志压缩机制。这种压缩机制会清除所有偏移量小于等于最小偏移量的消息，非常类似于基于“日志段”进行清理和合并。

在生产环境中，我们建议使用消息时间戳作为时间基准进行日志压缩，因为该时间戳不受系统时间更改的影响。下面是一个示例，说明如何向Kafka发送带有时间戳的消息：

Properties properties = new Properties();
properties.put("bootstrap.servers", "localhost:9092");
properties.put("acks", "all");
properties.put("retries", 0);
properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

Producer<String, String> producer = new KafkaProducer<>(properties);

long time = System.currentTimeMillis();

ProducerRecord<String, String> record = new ProducerRecord<>("my_topic", "key", "value", time);
producer.send(record);

producer.close();