Details
-
Improvement
-
Status: In Progress
-
Blocker
-
Resolution: Unresolved
-
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 request manager layer that timeouts are respected per the design in KAFKA-15848.
Attachments
Issue Links
- fixes
-
KAFKA-16460 New consumer times out consuming records in consumer_test.py system test
- Resolved
- is duplicated by
-
KAFKA-15475 Request might retry forever even if the user API timeout expires
- Resolved
- is related to
-
KAFKA-15848 Design solution for inconsistency between ConsumerDelegate timeout policies
- Resolved
- relates to
-
KAFKA-16427 KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER
- Resolved
-
KAFKA-15974 Enforce that event processing respects user-provided timeout
- Patch Available
- links to
- mentioned in
-
Page Loading...