Class StreamsGroupTopologyDescription.GlobalStore

java.lang.Object

org.apache.kafka.clients.admin.StreamsGroupTopologyDescription.GlobalStore

Enclosing class:

StreamsGroupTopologyDescription

public static class StreamsGroupTopologyDescription.GlobalStore
extends Object

A global state store, made up of a StreamsGroupTopologyDescription.Source node and the StreamsGroupTopologyDescription.Processor node that maintains the store.

Constructor Summary

Constructors

Constructor	Description
GlobalStore(StreamsGroupTopologyDescription.Source source, StreamsGroupTopologyDescription.Processor processor)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
StreamsGroupTopologyDescription.Processor	processor()	The processor node that maintains the global store.
StreamsGroupTopologyDescription.Source	source()	The source node providing data to the global store.
String	toString()

Methods inherited from class Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

GlobalStore

public GlobalStore(StreamsGroupTopologyDescription.Source source,
 StreamsGroupTopologyDescription.Processor processor)

Method Details

source

public StreamsGroupTopologyDescription.Source source()

The source node providing data to the global store.

processor

public StreamsGroupTopologyDescription.Processor processor()

The processor node that maintains the global store.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object