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)
