躺平才能躺赢 2023-01-05 21:34 采纳率: 25%
浏览 170
已结题

Kafka新加一个消费者,启动报错 RebalanceInProgressException: The group is rebalancing, so a rejoin is needed.

Join group failed with org.apache.kafka.common.errors.RebalanceInProgressException: The group is rebalancing, so a rejoin is needed.

execute error
org.apache.kafka.common.errors.InvalidTopicException: Invalid topics: [${kafka.consumer.topic.policyTopic}]

  • 写回答

1条回答 默认 最新

  • m0_54204465 2023-01-12 13:06
    关注

    这个错误信息 "RebalancelnProgressException: The group is rebalancing, so a rejoin is needed." 意思是组正在重新平衡,所以需要重新加入.
    这个错误通常发生在当一个新的消费者加入消费者组时,因为在这个过程中Kafka会自动触发重新平衡. 重新平衡的目的是将消息分配给所有消费者,以确保每个消费者都能消费到一定数量的消息. 在重新平衡过程中,新的消费者需要重新加入消费者组,以使其能够参与重新平衡.
    另外这个错误 Invalid topics: [${kafka.consumer.topic.policyTopic}] 表示消费者试图订阅一个无效的Topic.请检查代码,确保kafka.consumer.topic.policyTopic这个变量的值是正确的,并存在的Topic.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

  • 系统已结题 1月26日
  • 已采纳回答 1月18日
  • 专家修改了标签 1月13日
  • 请选择合适的标签 1月13日
  • 展开全部