Kafka消费群体中只有一个消费者的再平衡

Question

当一个组中只有一个消费者，并且认为消费者无法在session.time.out内进行轮询时，将触发重新平衡，但是在这种情况下，组中只有一个消费者，现在假设session.time.out是30秒和消费者民意调查后50秒组协调员将识别消费者后50秒，并允许它提交偏移或协调员将断开消费者和没有偏移得到提交，并将重新平衡消费者与新的消费者标识？如果上次提交的偏移量是345678，在下一次轮询中，它处理了直到345900的消息，但花了50秒（session.time.out是30），那么一旦重新平衡被触发，它会从345678读取还是从345900读取，还是从<--plhd--3开始/>：最新偏移量

Answer 1

消费者的数量不会改变协调员识别消费者的方式。如果消费者未在会话中进行轮询。超时。ms表示已经超过了心跳。间隔ms因此将触发重新平衡，当消费者在50秒后再次轮询时，它将被视为新消费者并分配新的消费者id。