Details
-
Improvement
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
None
Description
The intention of the CompletableApplicationEvent is for a Consumer to block waiting for the event to complete. The application thread will block for the timeout, but there is not yet a consistent manner in which events are timed out.
Enforce at the event handler/event processing layer that timeouts are respected per the design in KAFKA-15848.
Attachments
Issue Links
- fixes
-
KAFKA-16460 New consumer times out consuming records in multiple consumer_test.py system tests
- Reopened
- is duplicated by
-
KAFKA-16199 Prune the event queue if event timeout expired before starting
- Resolved
- is related to
-
KAFKA-15848 Design solution for inconsistency between ConsumerDelegate timeout policies
- Resolved
-
KAFKA-16200 Enforce that RequestManager implementations respect user-provided timeout
- Resolved
- relates to
-
KAFKA-16427 KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER
- Resolved
- links to
- mentioned in
-
Page Loading...