[
https://issues.apache.org/jira/browse/KAFKA-16659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16659.
------------------------------------
Fix Version/s: 3.8.0
Resolution: Fixed
> 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: PoAn Yang
> Priority: Minor
> Fix For: 3.8.0
>
>
> 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)
