使用Confluent客户端时刷新页面Topic消息消失问题咨询
Confluent Control Center Topic消息刷新后消失解决方案
核心排查方向(已确认Kafka服务端配置正常的前提下,问题均出在Control Center侧配置)
- 第一步:校验Control Center内部topic的保留策略
Control Center存储Web端展示的消息元数据依赖内部topic_confluent-controlcenter,该topic默认保留时间可能被初始化为极小值,导致消息元数据快速被清理。
执行以下命令查看该topic配置:
重点查看kafka-topics.sh --describe --topic _confluent-controlcenter --bootstrap-server <Kafka集群地址:端口>retention.ms参数,若数值小于3600000(1小时),执行以下命令调整保留时长(示例为保留1天,可按需调整):kafka-configs.sh --alter --entity-type topics --entity-name _confluent-controlcenter --add-config retention.ms=86400000 --bootstrap-server <Kafka集群地址:端口> - 第二步:修改Control Center消息拉取范围配置
默认Web端开启了仅展示当前会话临时消息的限制,在Topic详情页右上角的设置选项中,将消息加载范围从「Current session」切换为「All available messages」,同时将consumer.timeout.ms参数调整至30000以上,避免消费超时拉取不到历史消息。 - 第三步:排查浏览器存储限制
Control Center会将当前会话生产的临时消息存储在浏览器sessionStorage中,若浏览器开启了刷新/关闭页面自动清理会话存储的配置,会导致刷新后临时消息全部丢失。可在浏览器控制台「应用」标签页下查看sessionStorage中confluent相关条目,刷新后是否被清空即可验证。 - 第四步:校验账号ACL权限
若集群开启了ACL权限管控,需要确认当前登录账号对目标Topic拥有READ和DESCRIBE_CONFIGS权限,权限不足时Control Center不会拉取服务端历史消息,仅展示当前页面生产的临时消息,刷新后临时消息销毁即无内容展示。
内容的提问来源于stack exchange,提问作者cristhian gallo
相关产品推荐
相关产品推荐

