Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-15601 Client metrics and observability
  3. KAFKA-15662

Implement support for clientInstanceIds in Kafka Stream

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Patch Available
    • Major
    • Resolution: Unresolved
    • None
    • None
    • streams
    • None

    Description

      The KIP requires Kafka Stream to support below method to give access to the client instance ids of the producers, consumers and admin clients used by Kafka Streams.

       

      This method is only permitted when Kafka Streams is in state RUNNING or REBALANCING. In the event that Kafka Streams is not in state RUNNING or REBALANCING, the method throws org.apache.kafka.streams.errors.StreamsNotRunningException , which is a new subclass of InvalidStateStoreException .

       

      public ClientInstanceIds clientInstanceIds(Duration timeout); 

      Attachments

        Activity

          People

            mjsax Matthias J. Sax
            apoorvmittal10 Apoorv Mittal
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: