[
https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878022#comment-17878022
]
Chia-Ping Tsai commented on KAFKA-16792:
----------------------------------------
AsyncConsumer close(0) has similar issue that it needs to wait network thread
to trigger something. Hence, the “small” timeout will make the call
(poll/close) leave before network thread complete the event.
In summary, poll(0) could not trigger FC request when return and close(0) could
not trigger rebalance listener. Both are inconsistent behavior to classic
consumer.
We should document the new behavior if AsyncConsumer does want to honor the
timeout.
> Enable consumer unit tests that fail to fetch offsets only for new consumer
> with poll(0)
> ----------------------------------------------------------------------------------------
>
> Key: KAFKA-16792
> URL: https://issues.apache.org/jira/browse/KAFKA-16792
> Project: Kafka
> Issue Type: Test
> Components: clients, consumer, unit tests
> Reporter: Lianet Magrans
> Assignee: PoAn Yang
> Priority: Blocker
> Labels: kip-848-client-support
> Fix For: 4.0.0
>
>
> Enable the following unit tests for the new async consumer in
> KafkaConsumerTest:
> - testCurrentLag
> - testFetchStableOffsetThrowInPoll
> - testListOffsetShouldUpdateSubscriptions
> - testPollReturnsRecords
> - testResetToCommittedOffset
> - testResetUsingAutoResetPolicy
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
