[KAFKA-15974] Enforce that event processing respects user-provided timeout

• Type: Improvement
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 3.8.0
• Component/s: clients, consumer
• Labels: consumer-threading-refactor timeout
• Assignee: Kirk True
• Reporter: Kirk True
• Reviewer: Bruno Cadonna
• Created: 05/Dec/23 18:33
• Updated: 22/May/24 16:53
• Resolved: 22/May/24 16:40

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.

Issue Links

• fixes: KAFKA-16460 New consumer times out consuming records in multiple consumer_test.py system tests
• is duplicated by: KAFKA-16199 Prune the event queue if event timeout expired before starting
• is related to: KAFKA-15848 Design solution for inconsistency between ConsumerDelegate timeout policies
• is related to: KAFKA-16200 Enforce that RequestManager implementations respect user-provided timeout
• relates to: KAFKA-16427 KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER
• links to: GitHub Pull Request #15250
• links to: GitHub Pull Request #15640
• mentioned in: Page Loading...