Package com.bakdata.kafka.streams

Class StreamsAppConfiguration

java.lang.Object

com.bakdata.kafka.streams.StreamsAppConfiguration

public class StreamsAppConfiguration
extends Object

Configuration of a StreamsApp

Constructor Summary

Constructors

Constructor	Description
StreamsAppConfiguration(@NonNull StreamsTopicConfig topics, String uniqueAppId)
StreamsAppConfiguration(StreamsTopicConfig topics)	Create a new StreamsAppConfiguration with no provided uniqueAppId

Method Summary

Modifier and Type	Method	Description
@NonNull StreamsTopicConfig	getTopics()
Optional<String>	getUniqueAppId()	Get the provided unique application ID.

Methods inherited from class java.lang.Object

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

Constructor Details

StreamsAppConfiguration

public StreamsAppConfiguration(StreamsTopicConfig topics)

Create a new StreamsAppConfiguration with no provided uniqueAppId

Parameters:

topics - topics to use for app

StreamsAppConfiguration

public StreamsAppConfiguration(@NonNull
 @NonNull StreamsTopicConfig topics,
 String uniqueAppId)

Method Details

getUniqueAppId

public Optional<String> getUniqueAppId()

Get the provided unique application ID. If user did not provide a unique application ID, this will return empty.

Returns:

provided unique application ID

See Also:

• StreamsApp.getUniqueAppId(StreamsAppConfiguration)

getTopics

@NonNull
public @NonNull StreamsTopicConfig getTopics()