Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
-
None
Description
see following test
@ParameterizedTest(name = TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames) @MethodSource(Array("getTestQuorumAndGroupProtocolParametersAll")) @Timeout(15) def testPositionRespectsWakeup(quorum: String, groupProtocol: String): Unit = { val topicPartition = new TopicPartition(topic, 15) val consumer = createConsumer() consumer.assign(List(topicPartition).asJava) CompletableFuture.runAsync { () => TimeUnit.SECONDS.sleep(1) consumer.wakeup() } assertThrows(classOf[WakeupException], () => consumer.position(topicPartition, Duration.ofSeconds(3))) }
Attachments
Issue Links
- links to