[
https://issues.apache.org/jira/browse/KAFKA-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-10315:
-----------------------------------
Component/s: clients
> Consider to throw exception for failed fetch requests
> -----------------------------------------------------
>
> Key: KAFKA-10315
> URL: https://issues.apache.org/jira/browse/KAFKA-10315
> Project: Kafka
> Issue Type: New Feature
> Components: clients, consumer
> Reporter: Matthias J. Sax
> Assignee: Luke Chen
> Priority: Major
> Labels: need-kip
>
> The current `Consumer#poll(Duration)` method is designed to block until data
> is available or the provided poll timeout expires. This implies, that if
> fetch requests fail the consumer retries them internally and eventually
> returns an empty set of records. – Thus, from a user point of view, returning
> an empty set of records can mean that no data is available broker side or
> that the broker cannot be reached.
> For Kafka Streams, this behavior is problematic as its runtime would like to
> distinguish both cases, to apply its own timeouts (cf
> https://issues.apache.org/jira/browse/KAFKA-9274).
> One idea to address this issue is to add a new method `Consumer#pollOnce()`
> that would throw an exception if a fetch request fails instead of retrying
> internally.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
