https://issues.apache.org/jira/plugins/servlet/mobile#issue/KAFKA-12890
Check out this jira ticket בתאריך יום ב׳, 21 ביוני 2021, 22:15, מאת Tao Huang < sandy.huang...@gmail.com>: > Hi There, > > I am experiencing intermittent issue when consumer group stuck on > "Completing-Reblalance" state. When this is happening, client throws error > as below: > > 2021-06-18 13:55:41,086 ERROR io.mylab.adapter.KafkaListener > [edfKafkaListener:CIO.PandC.CIPG.InternalLoggingMetadataInfo] Exception on > Kafka listener (InternalLoggingMetadataInfo) - Some partitions are > unassigned but all consumers are at maximum capacity > java.lang.IllegalStateException: Some partitions are unassigned but all > consumers are at maximum capacity > at > > org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.constrainedAssign(AbstractStickyAssignor.java:248) > at > > org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.assign(AbstractStickyAssignor.java:81) > at > > org.apache.kafka.clients.consumer.CooperativeStickyAssignor.assign(CooperativeStickyAssignor.java:64) > at > > org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor.assign(AbstractPartitionAssignor.java:66) > at > > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.performAssignment(ConsumerCoordinator.java:589) > at > > org.apache.kafka.clients.consumer.internals.AbstractCoordinator.onJoinLeader(AbstractCoordinator.java:686) > at > > org.apache.kafka.clients.consumer.internals.AbstractCoordinator.access$1100(AbstractCoordinator.java:111) > at > > org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:599) > at > > org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:562) > at > > org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:1151) > at > > org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:1126) > at > > org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:206) > at > > org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:169) > at > > org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:129) > at > > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:602) > at > > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:412) > at > > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:297) > at > > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236) > at > > org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1296) > at > > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1237) > at > > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1210) > at io.mylab.adapter.KafkaListener.run(EdfKafkaListener.java:93) > at java.lang.Thread.run(Thread.java:748) > > The option to exit the state is to stop some members of the consumer group. > > Version: 2.6.1 > PARTITION_ASSIGNMENT_STRATEGY: CooperativeStickyAssignor > > Would you please advise what would be the condition to trigger such issue? > > Thanks! >
