消息记录留存策略

消息记录留存策略是指在使用Kafka作为消息队列时，如何设置消息的保存时间、保存大小以及删除策略等参数，以决定消息在Kafka中的留存时间和空间。

1. 消息保存时间：

Kafka中的消息有一个保存时间的配置参数，即log.retention.hours，默认值是7天。这个参数指定了一个消息在Kafka中保留的最大时间，超过该时间的消息将被删除。可以根据具体需求来调整该参数的值，以决定消息在Kafka中的留存时间。

2. 消息保存大小：

Kafka还有一个消息保存大小的配置参数，即log.retention.bytes，默认值是-1。这个参数用于限制消息在Kafka中的保存大小，单位是字节。当消息的大小超过该值时，Kafka会开始删除旧的消息，以保证保存的消息总大小不超过指定的值。如果将该参数设置为-1，则表示不限制消息的保存大小。

3. 删除策略：

Kafka支持两种删除消息的策略：delete和compact。默认情况下，删除策略是delete，即删除旧的消息，但不会删除最新的消息。当某个消息的所有副本都已经过期时，这个消息将被删除。

另一种删除策略compact，用于处理存储键值对的场景。当某个键对应的所有消息都已过期时，这个键和对应的所有消息都会被删除。这种删除策略主要用于保留最新的消息状态，适用于需要保留历史状态的场景。

配置方式

要配置Kafka的消息记录留存策略，可以通过修改Kafka的配置文件来实现。Kafka的配置文件是一个以键值对形式表示的文本文件，可以通过修改其中的配置参数的值来修改Kafka的行为。

1. 修改消息保存时间：

log.retention.hours=168

将log.retention.hours的值修改为168，表示将消息在Kafka中保留7天。

2. 修改消息保存大小：

log.retention.bytes=1073741824

将log.retention.bytes的值修改为1073741824，表示将消息在Kafka中的保存大小限制为1GB。

3. 修改删除策略：

log.cleanup.policy=compact

将log.cleanup.policy的值修改为compact，即使用紧凑型的删除策略。

通过修改Kafka的配置文件，可以灵活地调整消息记录留存策略，以适应不同的使用场景和需求。