Class StreamsInstanceStatus


  • public class StreamsInstanceStatus
    extends Object
    • Constructor Detail

      • StreamsInstanceStatus

        public StreamsInstanceStatus​(String applicationId,
                                     String state,
                                     Set<org.apache.kafka.streams.processor.ThreadMetadata> threads)
        Creates a new StreamsInstanceStatus instance.
        Parameters:
        threads - the set of ThreadMetadata instance.
    • Method Detail

      • getId

        public String getId()
      • getState

        public String getState()
      • getThreads

        public Set<org.apache.kafka.streams.processor.ThreadMetadata> getThreads()