Chia-Ping Tsai created KAFKA-16659: -------------------------------------- Summary: KafkaConsumer#position() does not respect wakup when group protocol is CONSUMER Key: KAFKA-16659 URL: https://issues.apache.org/jira/browse/KAFKA-16659 Project: Kafka Issue Type: Bug Reporter: Chia-Ping Tsai Assignee: Chia-Ping Tsai
see following test {code:scala} @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))) } {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)