秦山木槿花

0 声望

这家伙太懒，什么都没留下

个人动态
  • 关注了用户 半兽人 · 3年前
  • 秦山木槿花 回复 半兽人 在 kafka在数据迁移期间限制带宽的使用 中 ：

    迁移消费者组id咋知道嘞，我用consumer.group.sh --list查了下，没找到

    3年前
  • 秦山木槿花 回复 半兽人 在 kafka命令大全 中 ：

    我还是下午问你的那个小白，扳手哥
    你让我看那个迁移分区对应的消费组lag情况，我想了下
    可是我迁移的这个分区，ISR 中已经出现了我的目标地址（broker_id）了，我个人觉得这个迁移的消费者组id对应的lag已经为0了（我也找不到。。这个消费者组id。。。）
    我看了源码的注释
    这是分区迁移的流程
    我认为我现在已经到了第八步，在第九步或者第10步卡住了

      * For example, if OAR = {1, 2, 3} and RAR = {4,5,6}, the values in the assigned replica (AR) and leader/isr path in ZK
   * may go through the following transition.
   * AR                 leader/isr
   * {1,2,3}            1/{1,2,3}           (initial state)
   * {1,2,3,4,5,6}      1/{1,2,3}           (step 2)
   * {1,2,3,4,5,6}      1/{1,2,3,4,5,6}     (step 4)
   * {1,2,3,4,5,6}      4/{1,2,3,4,5,6}     (step 7)
   * {1,2,3,4,5,6}      4/{4,5,6}           (step 8)
   * {4,5,6}            4/{4,5,6}           (step 10)
   *
    3年前
  • 半兽人 回复 秦山木槿花 在 kafka在数据迁移期间限制带宽的使用 中 ：

    参考命令：https://www.orchome.com/454
    有查询集群的命令，步骤：
    1、查询消费者组列表。
    2、拿到消费者组列表后，查看迁移消费者组详情。
    3、看看lag延迟差距多少。

    如果lag持续在减少，那继续等待吧，反之，持续新增的数据比同步的速度快，那你新建个分区，将消息推倒新分区上。

    3年前
  • 秦山木槿花 回复 半兽人 在 kafka在数据迁移期间限制带宽的使用 中 ：

    等了2天了没反应

    3年前
  • 秦山木槿花 回复 半兽人 在 kafka在数据迁移期间限制带宽的使用 中 ：

    啥命令看迁移进度啊？
    我只知道verify。。。。然后就一直in progress了

    3年前