文档中心

消息队列 Kafka版

实例运维

修改参数配置

创建 Kafka 实例后，您可以根据业务需求修改实例或 Topic 级别的参数配置，例如最大消息大小、消息保留时长等。

背景信息

消息队列 Kafka版在实例与 Topic 级别均提供了部分参数的在线可视化配置，指定不同场景下的各种消息策略，例如通过消息保留时长配置消息过期删除策略、参数磁盘清理水位配置磁盘容量阈值策略等等。

说明

实例级别的参数配置决定了实例各项参数的默认参数值，即修改实例参数配置后，再创建的 Topic 默认参数值为实例的参数配置。实际生效的消息保留时长等配置，以各个 Topic 的参数配置为准。

磁盘容量阈值策略

设置消息保留时长后，如果实例的磁盘容量充足，过期的消息会被按时自动删除。如果业务在短时间内消息猛增，此时尚未过期的消息快速填满了某个 Broker 或全部实例的磁盘空间，可能造成生产和消费的异常。消息队列 Kafka版在磁盘容量不足时，通过阈值策略管理保证服务的可用性。

Kafka 实例支持自定义设置磁盘清理水位，且每个 Broker 的磁盘清理水位相同。如果实例整体磁盘使用率达到清理水位，或因数据不均衡导致某个 Broker 的磁盘使用率达到清理水位时，无论消息是否超过消息保留时长，都会按服务端存储消息的时间先后顺序删除该节点的部分历史消息，直至磁盘水位恢复，避免磁盘使用率过高导致 Kafka 实例异常，以及避免因节点无法同步数据导致的副本不同步。

说明

触发自动删除策略时，如果消息写入速率超过了磁盘自动清理的速度，后端服务会在磁盘被写满前暂停写入数据。

推荐设置 Broker 磁盘容量的阈值监控告警，在磁盘使用率接近清理水位之前及时处理，避免消息在自然老化前被删除。推荐设置的告警策略请参考实例磁盘使用容量超过 30% 且磁盘倾斜率超过 30%。

消息过期删除策略

消息队列 Kafka版提供消息的过期删除策略管理，即通过参数消息保留时长配置磁盘容量充足时，消息存储在服务端的时长。

磁盘容量充足时，服务端定期检查并自动清理超过保留时长的消息，但每个分区会至少保留一个当前使用的 log 文件，因而可能有些消息超过时限却依然保留着。因此，您有可能查询到超过消息保留时间的消息。

注意事项

修改实例的参数配置，不影响所有已创建的 Topic 参数配置。假设 Topic 已经设置了最大消息大小和消息保留时长，在实例级别修改最大消息大小和消息保留时长对此 Topic 不生效。

修改实例的消费位点保留时长将引发实例滚动重启，请确认业务侧已配置了自动重连等策略。

修改最大消息大小（MessageMaxByte）之前，请确认新的消息大小和生产与消费客户端配置相匹配，否则可能会出现消息丢失的情况。

修改实例的参数配置

说明

修改实例的参数配置之前，应确认 Kafka 实例状态为运行中。

登录消息队列 Kafka版控制台。

在顶部菜单栏中选择实例所在的地域。

在实例列表页面单击指定实例名称。

在实例详情页签的参数配置区域单击修改。

填写新的参数配置，并单击保存。

参数	说明
最大消息大小	单条消息的最大长度，即消息队列 Kafka版能收发的消息的最大值。该参数设置需要和生产与消费客户端配置相匹配，否则可能会出现消息丢失的情况。单位为 MB，取值范围为 1～12。默认值为 10。
消息保留时长	在磁盘容量充足的情况下，消息的最大保留时长，即消息的存储时间。单位为小时，取值范围为 1～2160，即消息最久保留 90 天。磁盘容量达到 90% 时，为确保服务可用性，后端服务会提前删除部分历史消息，详细说明请参考磁盘容量阈值策略。
消费位点保留时长	消费位点的最大保留时长。从提交消费位点的时间开始计算，超过该时长的消费位点将被删除。每向一个 Topic 分区提交一次消费位点，该消费位点的保留时间就会被重置，即从 0 开始计算。单位为分钟，取值范围为 1～10080，即消费位点最久保留 7 天。默认值为 4320 分钟，即 3 天。说明修改实例的消费位点保留时长将引发实例滚动重启，可能会出现服务的短暂不可用。建议您在客户端实现重连机制，以避免客户端断开连接无法重连。
消息时间类型	消息时间戳类型。默认设置为 CreateTime。支持设置为： LogAppendTime：使用服务端写入消息的时间作为消息时间戳。 CreateTime：使用 Producer 创建消息的时间，也就是客户端传入的消息时间戳（CreateTime）作为消息时间戳。
自动删除Group	是否自动删除 Group。默认为关闭状态。开启后，如果消费者组中的所有消费者处于 Empty 状态，超出消费位点保留时长后会自动删除该消费者组。关闭后，消费进度的自动删除不影响消费组的状态，Empty 状态的 Group 不会被自动删除。说明修改该参数配置将引发实例滚动重启，可能会出现服务的短暂不可用。建议您在客户端实现重连机制，以避免客户端断开连接无法重连。

在弹出对话框中确认修改的参数名称及修改前后的运行值，单击确定。

修改 Topic 的参数配置

说明

Kafka 实例状态为运行中，且Topic状态为服务中时，才能修改 Topic 的参数配置。

登录消息队列 Kafka版控制台。

在顶部菜单栏中选择实例所在的地域。

在实例列表页面单击指定实例名称。

在顶部页签栏中单击Topic管理。

找到目标 Topic，并在其对应的操作列单击修改配置。

填写相关配置参数，并单击保存。

参数	说明
分区数	此 Topic 的分区数量。分区数量越大，消费的并发度越大。默认值为 12，取值范围为 1～300。分区数量应为 Broker 数量的整数倍，您可以参考查看节点信息查看当前实例的 Broker 数量。该参数只能调大不能调小，且不可超过 Kafka 实例的剩余可用分区数。
副本数	分区的副本个数，表示在对应数量的副本上备份数据，用于保障分区的高可用。当其中一个 Broker 故障时仍可保障数据可用性，副本数越大可靠性越高。副本数支持设置为 1、2 或 3，默认为 3。说明增加副本数会占用实例磁盘容量，请确保容量充足。增加副本时会占用实例带宽资源，建议在业务低峰期操作。减少副本数会降低数据可用性，请谨慎操作。 1 副本 Topic 无法保障数据可靠性且实例升级期间无法进行读写操作，建议选择 2 副本或 3 副本。
最小同步副本数	Topic 最小同步副本个数，即 min.insync.replicas 参数。该值越大，数据可靠性越好，但是可用性将会降低。副本数为 1 时，最小同步副本数只能为 1。副本数为 2 或 3 时，最小同步副本数不能超过副本数减 1。
消息保留时长	磁盘容量充足时，消息在此 Topic 中的最大保留时长，即消息的存储时间。消费者必须在此时间结束前消费消息，否则消息将被删除，删除的消息无法被消费。单位为小时，取值范围为 0～2160，目前支持的最大存储时长为 90 天。默认为实例级别的消息保留时长，您也可以在此处指定该 Topic 的消息保留时长，仅对该 Topic 生效。
最大消息大小	此 Topic 中单条消息的最大长度。取值范围为 1MB～12MB。默认为实例级别的最大消息大小，您也可以在此处指定该 Topic 的最大消息大小，仅对该 Topic 生效。
消息清理策略	Topic 的消息清理策略。 DELETE：默认的消息清理策略。在磁盘容量充足的情况下，保留在最长保留时间范围内的消息；在磁盘容量不足时，将提前删除旧消息，以保证服务可用性。 COMPACT：COMPACT 消息清理策略针对每个消息的 Key 进行整合，对于有相同 Key 的消息，只保留最新的 value 值，旧的记录则会被清除。 DELETE,COMPACT：同时配置 DELETE 和 COMPACT 两种消息清理策略。只要消息满足任一条清理策略时，都将被清除。

在弹出对话框中确认修改的参数名称及修改前后的运行值，单击确定。

最近更新时间：2025.08.08 17:47:27

这个页面对您有帮助吗？

有用

无用