我在Kafkajs的消费者方面有优势,有时我会犯一个再平衡错误:[Connection] ResponseHeartbeat(key: 12, version: 3)[Runner] The group isrebalancing, re-joining
然后,一旦使用者组被重新平衡,被处理的最后一条消息将再次被处理,因为由于错误而没有发生提交。
clientId=consumer-periodicSync-5, groupId=periodicSync] Attempt to heartbeat failed since group is rebalancingclientId=consumer-periodicSync-5, groupId=periodicSync] Attempt to heartbeat failed since group is rebalancing
currently an exception: XDMP-FORESTERR: Error in rebalance of forest rsuite-f2: XDMP-REBALANCE: Error rebalancingcurrently an exception: XDMP-FORESTERR: Error in rebalance of forest rsuite: XDMP-REBALANCE: Error rebalancing
Consumer clientId=consumer-1, groupId=com.stellapps.rtc] Attempt to heartbeat failed since group is rebalancingConsumer clientId=consumer-1, groupId=com.stellapps.rtc] Attempt to heartbeat failed since group is rebalancingConsumer clientId=consumer-1, groupId=com.stellapps.rtc] Att
org.apache.ignite.internal.processors.platform.PlatformIgnition.start(PlatformIgnition.java:76)[13:24:07] Cancelled rebalancing from all nodes [topology=null]
AbstractCoordinator.java:988|[Consumer clientId=consumer-t1-7, groupId=t1] Request joining group due to: group is already rebalancingAbstractCoordinator.java:988|[Consumer clientId=consumer-t1-7, groupId=t1] Request joining group due to: group is already rebalancingAbstractCoordina