Details
-
Sub-task
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
Description
Access to the committed offsets via a call to the committed API func works as expected for a single async consumer, but it some times fails with timeout when trying to retrieve the committed offsets with another consumer in the same group (test testConsumeFromCommittedOffsets on BaseAsynConsumerTest)
Attachments
Issue Links
- is part of
-
KAFKA-14246 Update threading model for Consumer
- Resolved