Boyang Chen created KAFKA-8589:
----------------------------------
Summary: Flakey test
ResetConsumerGroupOffsetTest#testResetOffsetsExistingTopic
Key: KAFKA-8589
URL: https://issues.apache.org/jira/browse/KAFKA-8589
Project: Kafka
Issue Type: Bug
Reporter: Boyang Chen
[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.3#76005)
