[
https://issues.apache.org/jira/browse/KAFKA-16659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16659:
--------------------------------------
Assignee: PoAn Yang (was: Chia-Ping Tsai)
> 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
>
> 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)
