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

Implement more of the remaining PrototypeAsyncConsumer APIs

    XMLWordPrintableJSON

Details

    Description

      There are several Consumer APIs that only touch the ConsumerMetadata and/or SubscriptionState classes; they do not perform network I/O or otherwise block. These can be implemented without needing RequestManager updates and include the following APIs:

      • committed
      • currentLag
      • metrics
      • pause
      • paused
      • position
      • resume
      • seek
      • seekToBeginning
      • seekToEnd
      • subscribe

      Attachments

        Issue Links

          Activity

            People

              kirktrue Kirk True
              kirktrue Kirk True
              Jun Rao Jun Rao
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: