[
https://issues.apache.org/jira/browse/KAFKA-8589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8589:
-----------------------------------
Component/s: clients
admin
> Flakey test ResetConsumerGroupOffsetTest#testResetOffsetsExistingTopic
> ----------------------------------------------------------------------
>
> Key: KAFKA-8589
> URL: https://issues.apache.org/jira/browse/KAFKA-8589
> Project: Kafka
> Issue Type: Bug
> Components: admin, clients, unit tests
> Reporter: Boyang Chen
> Priority: Major
>
> [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/5724/consoleFull]
> *20:25:15*
> kafka.admin.ResetConsumerGroupOffsetTest.testResetOffsetsExistingTopic
> failed, log available in
> /home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.12/core/build/reports/testOutput/kafka.admin.ResetConsumerGroupOffsetTest.testResetOffsetsExistingTopic.test.stdout*20:25:15*
> *20:25:15* kafka.admin.ResetConsumerGroupOffsetTest >
> testResetOffsetsExistingTopic FAILED*20:25:15*
> java.util.concurrent.ExecutionException:
> org.apache.kafka.common.errors.CoordinatorNotAvailableException: The
> coordinator is not available.*20:25:15* at
> org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)*20:25:15*
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)*20:25:15*
> at
> org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)*20:25:15*
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)*20:25:15*
> at
> kafka.admin.ConsumerGroupCommand$ConsumerGroupService.$anonfun$resetOffsets$1(ConsumerGroupCommand.scala:379)*20:25:15*
> at
> scala.collection.TraversableOnce.$anonfun$foldLeft$1(TraversableOnce.scala:160)*20:25:15*
> at
> scala.collection.TraversableOnce.$anonfun$foldLeft$1$adapted(TraversableOnce.scala:160)*20:25:15*
> at scala.collection.Iterator.foreach(Iterator.scala:941)*20:25:15*
> at scala.collection.Iterator.foreach$(Iterator.scala:941)*20:25:15*
> at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1429)*20:25:15*
> at scala.collection.IterableLike.foreach(IterableLike.scala:74)*20:25:15*
> at
> scala.collection.IterableLike.foreach$(IterableLike.scala:73)*20:25:15*
> at scala.collection.AbstractIterable.foreach(Iterable.scala:56)*20:25:15*
> at
> scala.collection.TraversableOnce.foldLeft(TraversableOnce.scala:160)*20:25:15*
> at
> scala.collection.TraversableOnce.foldLeft$(TraversableOnce.scala:158)*20:25:15*
> at
> scala.collection.AbstractTraversable.foldLeft(Traversable.scala:108)*20:25:15*
> at
> kafka.admin.ConsumerGroupCommand$ConsumerGroupService.resetOffsets(ConsumerGroupCommand.scala:377)*20:25:15*
> at
> kafka.admin.ResetConsumerGroupOffsetTest.resetOffsets(ResetConsumerGroupOffsetTest.scala:507)*20:25:15*
> at
> kafka.admin.ResetConsumerGroupOffsetTest.resetAndAssertOffsets(ResetConsumerGroupOffsetTest.scala:477)*20:25:15*
> at
> kafka.admin.ResetConsumerGroupOffsetTest.testResetOffsetsExistingTopic(ResetConsumerGroupOffsetTest.scala:123)*20:25:15*
> *20:25:15* Caused by:*20:25:15*
> org.apache.kafka.common.errors.CoordinatorNotAvailableException: The
> coordinator is not available.*20*
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
