Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14246 Update threading model for Consumer
  3. KAFKA-15270

Integration tests for AsyncConsumer simple consume case

Attach filesAttach ScreenshotVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    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

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            lianetm Lianet Magrans
            lianetm Lianet Magrans
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment