Details
-
Sub-task
-
Status: Resolved
-
Blocker
-
Resolution: Duplicate
-
None
-
None
Description
This task involves writing integration tests for covering the simple consume functionality of the AsyncConsumer. This should include validation of the assign, fetch and positions logic.
Not covering any committed offset functionality as part of this task.
Integration tests should have a similar form as the existing PlaintextConsumerTest, but scoped to the simple consume flow.
Attachments
Attachments
Issue Links
- is part of
-
KAFKA-14246 Update threading model for Consumer
- Resolved
- is superceded by
-
KAFKA-15544 Enable existing client integration tests for new protocol
- Resolved
- links to