Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14048 The Next Generation of the Consumer Rebalance Protocol
  3. KAFKA-15283

Client support for OffsetFetch and OffsetCommit with topic ID

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    Description

      Currently, KafkaConsumer keeps track of topic IDs in the in-memory ConsumerMetadata object, and they are provided to the FETCH and METADATA RPC calls.

      With KIP-848 the OffsetFetch and OffsetCommit will start using topic IDs in the same way, so the new client implementation will provide it when issuing those requests. Topic names should continue to be supported as needed by the AdminClient.

      We should also review/clean-up the support for topic names in requests such as the METADATA request (currently supporting topic names as well as topic IDs on the client side).

      Tasks include:

      • Introduce Topic ID in existing OffsetFetch and OffsetCommit API that will be upgraded on the server to support topic ID
      • Check topic ID propagation internally in the client based on RPCs including it.
      • Review existing support for topic name for potential clean if not needed.

      Attachments

        Issue Links

        Activity

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

          People

            lianetm Lianet Magrans
            kirktrue Kirk True

            Dates

              Created:
              Updated:

              Slack

                Issue deployment