重新平衡是由于长时间运行的消费者线程[#T1]而发生的--相同的线程会加入重新平衡吗？
我想知道当重新平衡发生时，当前处理使用者线程会发生什么？
使用者线程#T1->调用一些服务，并等待套接字超时，该超时是无限的。这意味着线程#t1在最坏的情况下不会再次调用poll。一旦超过50万次，这种再平衡就被触发了
使用者线程#T2和使用者线程#T3->将参与poll（）方法调用的重新平衡，因为它们工作正常。
现在，线程t1在再平衡时会发生什么？
-
null
共有1个答案
线程不会被杀死（或中断，但套接字读取无论如何都是不可中断的，您需要设置超时）。
当线程最终返回时（如果返回了），它将触发另一个再平衡。
-
我们正在运行一个3 broker Kafka 0.10.0.1集群。我们有一个java应用程序，它产生了许多消费线程，从不同的主题消费。对于每一个主题，我们都指定了不同的消费者群体。 很多时候，我看到每当这个应用程序重新启动时，一个或多个CG需要超过5分钟来接收分区分配。在此之前，这个话题的消费者不会消费任何东西。如果我去Kafka broker并运行Consumer-Groups.sh并描述特定
-
我有一个关于2个代理上的3个分区的主题。（Kafka版本:0.8.1) 使用不同的用户guid（如:FC42B34DD7658503E040970A2C437358)作为分区密钥批量添加消息。（约10K条消息） 在加载消息时，我有一个正在运行的消费者(consumer1)，它开始很好地处理消息。 然后我用相同的消费者组ID启动了另一个消费者(consumer2)。 我希望两个消费者都应该分配负载。
-
我有一个微服务应用程序，它是使用camel kafka开发的，用于消费来自kafka的消息。我用4个并发实例运行这个服务，其中每个实例都有1个消费者，他们消费的主题有20个分区。 在维护期间（每天凌晨1-2点），应用程序将通过停止消费者来暂停消费。 当应用程序暂停消费时，kafka重新平衡发生，一些实例将在停止消费之前分配更多分区。 e、 由instanceA（partition1-5）使用的g分
-
根据Kafka的文件： kafka保证主题分区只分配给组中的一个消费者。 但我在服务中观察到了不同的行为。以下是一些细节： 我用的是Kafka2.8和SpringKafka2.2.13。 最初我有一个Kafka主题包含5个分区，这个主题在我的服务中使用了Spring和ConcurrentKafkAlisterContainerFactory中的注释，并发性=5。这个配置对我来说很好。 后来，我开始
-
我用的是Kafka：2.11-1.0.1。应用程序包含主题“X”的并发性为5的使用者，分区为5。 重新启动应用程序并在分区分配之前在主题“X”上发布消息时，主题“X”的5个使用者会找到组协调器，并将加入组请求发送给组协调器。预计会收到小组协调员的回复，但未收到回复。 我检查了Kafka服务器日志，但在调试日志级别找不到相关日志。 当我运行描述消费者组的命令时，作出如下观察： 消费群体正在重新平衡
-
我有一个带注释的kafka消费者方法@kafkalistener。我已经在容器上设置了重试模板，并且重试配置是这样的，如果在处理消息时发生了一些异常，它将始终重试。我已将最大轮询记录设置为1。如果这种情况实时发生，并且消费者一直在重试消息，经纪人会认为该消费者已经死亡并触发重新平衡吗？或者，在重试时，消费者是否会对未能处理的相同消息进行投票？如果这是真的，因为民意调查正在进行，我的假设是不会有任何