Details
-
Bug
-
Status: Open
-
Critical
-
Resolution: Unresolved
-
2.2.0
-
None
Description
java.lang.AssertionError: Expected that consumer group has consumed all messages from topic/partition. at kafka.utils.TestUtils$.fail(TestUtils.scala:381) at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:791) at kafka.admin.ResetConsumerGroupOffsetTest.awaitConsumerProgress(ResetConsumerGroupOffsetTest.scala:364) at kafka.admin.ResetConsumerGroupOffsetTest.produceConsumeAndShutdown(ResetConsumerGroupOffsetTest.scala:359) at kafka.admin.ResetConsumerGroupOffsetTest.testResetOffsetsByDuration(ResetConsumerGroupOffsetTest.scala:146)
STDOUT
[2019-03-09 08:39:29,856] WARN Unable to read additional data from client sessionid 0x105f6adb2080000, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376) [2019-03-09 08:39:46,373] WARN Unable to read additional data from client sessionid 0x105f6adf4c50001, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
Attachments
Issue Links
- is related to
-
KAFKA-7937 Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup
- Resolved