当前位置: 首页 > article >正文

Kafka系列之:定位topic只能保存最新数据的原因

Kafka系列之:定位topic只能保存最新数据的原因

  • 一、背景
  • 二、定位排查方向
  • 三、深入排查

一、背景

  • kafka topic保存的数据少,topic只能保存最新的数据

二、定位排查方向

  • 能想到的定位排查方向:topic能存储的数据量、topic数据保存的时间、topic数据大小

./bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name optics_rt --describe

Topic: optics_rt TopicId: W37WLzYSRe6pwgYMOprw8w PartitionCount: 6 ReplicationFactor: 3 Configs: retention.bytes=5368709120
Topic: optics_rt Partition: 0 Leader: 2 Replicas: 2,4,3 Isr: 2,3,4
Topic: optics_rt Partition: 1 Leader: 3 Replicas: 3,2,0 Isr: 0,2,3
Topic: optics_rt Partition: 2 Leader: 0 Replicas: 0,3,5 Isr: 0,3,5
Topic: optics_rt Partition: 3 Leader: 5 Replicas: 5,0,1 Isr: 0,1,5
Topic: optics_rt Partition: 4 Leader: 1 R


http://www.kler.cn/a/537632.html

相关文章:

  • 声明式导航,编程式导航,导航传参,下拉刷新
  • 【STM32系列】利用MATLAB配合ARM-DSP库设计IIR数字滤波器(保姆级教程)
  • 【Leetcode 每日一题】47. 全排列 II
  • 批量提取word表格数据到一个excel
  • 98.2 AI量化开发:基于DeepSeek打造个人专属金融消息面-AI量化分析师(理论+全套Python代码)
  • 20240206 adb 连不上手机解决办法
  • 全国计算机等级考试(NCRE)四级计算机网络考试大纲(2025年版)
  • Vite 为什么快,是怎么打包的
  • C# OpenCV机器视觉:智能水果采摘
  • 卷积神经网络(CNN)池化层的最大池化(Max Pooling)和 平均池化(Average Pooling)
  • Spring MVC异常处理:DefaultHandlerExceptionResolver的使用与实例
  • JDK实现动态代理介绍+案例
  • Termux安装ssh实现电脑ssh
  • 详解在Pytest中忽略测试目录的三种方法
  • DeepSeek:从入门到精通(100页PDF)
  • MySQL InnoDB引擎 事务隔离级别
  • 【AIGC】冷启动数据与多阶段训练在 DeepSeek 中的作用
  • 网络编程day2-套接字与TPC服务器与客户端的搭建
  • 什么是java中的线程同步
  • 【Python实战练习】Python类中的方法:形式与作用详解
  • 三次方程的几何新视界:双曲线-抛物线交点法与旋转圆系法
  • 去除 RequestTemplate 对象中的指定请求头
  • 优惠券平台(十二):EasyExcel解析实现用户优惠券分发(2)
  • 未来AI医院蓝图:源码、机器人与数字孪生如何打造智能医疗APP?
  • ArcGIS技术与土地利用分析全流程实践----从数据管理到建模预测
  • AIGC-PPT创作智能体完整指令(DeepSeek,豆包,千问,Kimi,GPT)