当一个组中只有一个使用者，并且认为该使用者无法在session.time.out内进行轮询时，将触发重新平衡，但在这种情况下，组中只有一个使用者，现在假设session.time.out为30秒，50秒后的消费者投票将是group Coordinator在50秒后识别消费者并允许其提交补偿，还是Coordinator将断开消费者的连接，并且没有提交补偿，并将使用新的消费者id重新平衡消费者？如果上一次提交的偏移量是345678，并且在下一次轮询中它已经处理了消息，直到345900，但是花费了50秒（session.time.out是30秒），那么一旦触发重新平衡，它将从345678或345900读取，或者从auto.offset开始。reset:latest offset
1条答案
按热度按时间sxpgvts31#
消费者的数量不会改变协调员识别他们的方式。如果消费者在
session.timeout.ms这意味着它已经超过了heartbeat.interval.ms因此，重新平衡将被触发，当消费者在50秒后再次轮询时，它将被视为一个新的消费者，并被分配一个新的消费者id。