Class StreamsMetadata

java.lang.Object
org.apache.kafka.streams.state.StreamsMetadata

@Deprecated public class StreamsMetadata extends Object
Deprecated.
since 3.0.0 use StreamsMetadata
Represents the state of an instance (process) in a KafkaStreams application. It contains the user supplied HostInfo that can be used by developers to build APIs and services to connect to other instances, the Set of state stores available on the instance and the Set of TopicPartitions available on the instance. NOTE: This is a point in time view. It may change when rebalances happen.
  • Field Details

    • NOT_AVAILABLE

      public static final StreamsMetadata NOT_AVAILABLE
      Deprecated.
      Sentinel to indicate that the StreamsMetadata is currently unavailable. This can occur during rebalance operations.
  • Constructor Details

  • Method Details

    • hostInfo

      public HostInfo hostInfo()
      Deprecated.
      The value of StreamsConfig.APPLICATION_SERVER_CONFIG configured for the streams instance, which is typically host/port
      Returns:
      HostInfo corresponding to the streams instance
    • stateStoreNames

      public Set<String> stateStoreNames()
      Deprecated.
      State stores owned by the instance as an active replica
      Returns:
      set of active state store names
    • topicPartitions

      public Set<TopicPartition> topicPartitions()
      Deprecated.
      Topic partitions consumed by the instance as an active replica
      Returns:
      set of active topic partitions
    • standbyTopicPartitions

      public Set<TopicPartition> standbyTopicPartitions()
      Deprecated.
      (Source) Topic partitions for which the instance acts as standby.
      Returns:
      set of standby topic partitions
    • standbyStateStoreNames

      public Set<String> standbyStateStoreNames()
      Deprecated.
      State stores owned by the instance as a standby replica
      Returns:
      set of standby state store names
    • host

      public String host()
      Deprecated.
    • port

      public int port()
      Deprecated.
    • equals

      public boolean equals(Object o)
      Deprecated.
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Deprecated.
      Overrides:
      hashCode in class Object
    • toString

      public String toString()
      Deprecated.
      Overrides:
      toString in class Object