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