Package io.streamthoughts.azkarra.api.streams

Class KafkaStreamsContainer

java.lang.Object

io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer

public class KafkaStreamsContainer
extends Object

Method Summary

Modifier and Type	Method	Description
String	applicationId()	Gets configured StreamsConfig.APPLICATION_ID_CONFIG for this KafkaStreams instance.
void	close()	Closes this KafkaStreams instance.
void	close(boolean cleanUp)	Closes this KafkaStreams instance.
Optional<Throwable>	exception()	Gets the last observed exception thrown the KafkaStreams instance.
Set<StreamsServerInfo>	getAllMetadata()
Collection<StreamsServerInfo>	getAllMetadataForStore(String storeName)
Optional<org.apache.kafka.common.serialization.Serde>	getDefaultKeySerde()	Gets the default Serde configured for key.
<K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V>>	getLocalKeyValueStore(String storeName)
Optional<StreamsServerInfo>	getLocalServerInfo()
<K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlySessionStore<K,V>>	getLocalSessionStore(String storeName)
<T> LocalStoreAccessor<T>	getLocalStoreAccess(String storeName, org.apache.kafka.streams.state.QueryableStoreType<T> storeType)
<K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>>	getLocalWindowStore(String storeName)
<K> StreamsServerInfo	getMetadataForStoreAndKey(String storeName, K key, org.apache.kafka.common.serialization.Serializer<K> keySerializer)
Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric>	metrics()	Gets all the current Metrics for this KafkaStreams instance.
void	restart()
Future<org.apache.kafka.streams.KafkaStreams.State>	start(Executor executor, boolean waitForTopicsToBeCreated)	Asynchronously start the underlying KafkaStreams instance.
long	startedSince()	Gets the started epoch-time in milliseconds.
TimestampedValue<State>	state()	Gets the current state of the streams.
Conf	streamsConfig()	Gets the configuration for this KafkaStreams instance.
Set<org.apache.kafka.streams.processor.ThreadMetadata>	threadMetadata()	Gets the local thread metadata.
TopologyMetadata	topologyMetadata()	Gets the TopologyMetadata about the topology runs by this KafkaStreams instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

start

public Future<org.apache.kafka.streams.KafkaStreams.State> start(Executor executor,
                                                                 boolean waitForTopicsToBeCreated)

Asynchronously start the underlying KafkaStreams instance.

Parameters:

executor - the Executor instance to be used for starting the streams.

waitForTopicsToBeCreated - should wait for source topics to be created before starting.

Returns:

the future KafkaStreams.State of the streams.

state

public TimestampedValue<State> state()

Gets the current state of the streams.

Returns:

a TimestampedValue instance;

getDefaultKeySerde

public Optional<org.apache.kafka.common.serialization.Serde> getDefaultKeySerde()

Gets the default Serde configured for key.

Returns:

a optional Serde instance.

threadMetadata

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

Gets the local thread metadata.

Returns:

a set of ThreadMetadata instance.

startedSince

public long startedSince()

Gets the started epoch-time in milliseconds.

Returns:

a unix epoch-time in milliseconds.

streamsConfig

public Conf streamsConfig()

Gets the configuration for this KafkaStreams instance.

Returns:

a Conf instance.

applicationId

public String applicationId()

Gets configured StreamsConfig.APPLICATION_ID_CONFIG for this KafkaStreams instance.

Returns:

a string application.id.

exception

public Optional<Throwable> exception()

Gets the last observed exception thrown the KafkaStreams instance.

Returns:

a Throwable instance.

topologyMetadata

public TopologyMetadata topologyMetadata()

Gets the TopologyMetadata about the topology runs by this KafkaStreams instance.

Returns:

a TopologyMetadata instance.

metrics

public Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> metrics()

Gets all the current Metrics for this KafkaStreams instance.

Returns:

a map of Metric.

close

public void close()

Closes this KafkaStreams instance.

close

public void close(boolean cleanUp)

Closes this KafkaStreams instance.

Parameters:

cleanUp - flag to clean up the local streams states.

restart

public void restart()

getLocalServerInfo

public Optional<StreamsServerInfo> getLocalServerInfo()

getAllMetadata

public Set<StreamsServerInfo> getAllMetadata()

getAllMetadataForStore

public Collection<StreamsServerInfo> getAllMetadataForStore(String storeName)

getMetadataForStoreAndKey

public <K> StreamsServerInfo getMetadataForStoreAndKey(String storeName,
                                                       K key,
                                                       org.apache.kafka.common.serialization.Serializer<K> keySerializer)

getLocalKeyValueStore

public <K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V>> getLocalKeyValueStore(String storeName)

getLocalWindowStore

public <K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>> getLocalWindowStore(String storeName)

getLocalSessionStore

public <K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlySessionStore<K,V>> getLocalSessionStore(String storeName)

getLocalStoreAccess

public <T> LocalStoreAccessor<T> getLocalStoreAccess(String storeName,
                                                     org.apache.kafka.streams.state.QueryableStoreType<T> storeType)