[ 
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)

Reply via email to