Class StreamsGroupSubtopology

java.lang.Object
io.confluent.kafkarest.entities.StreamsGroupSubtopology

public abstract class StreamsGroupSubtopology extends Object
  • Method Details

    • getClusterId

      public abstract String getClusterId()
    • getStreamsGroupId

      public abstract String getStreamsGroupId()
    • getSubtopologyId

      public abstract String getSubtopologyId()
    • getSourceTopics

      public abstract com.google.common.collect.ImmutableList<String> getSourceTopics()
    • builder

      public static StreamsGroupSubtopology.Builder builder()
    • fromSubtopologyDescription

      public static StreamsGroupSubtopology fromSubtopologyDescription(String clusterId, String streamsGroupId, org.apache.kafka.clients.admin.StreamsGroupSubtopologyDescription description)