Package com.bakdata.kafka.consumerproducer

Class ConsumerProducerAppConfiguration

java.lang.Object

com.bakdata.kafka.consumerproducer.ConsumerProducerAppConfiguration

public class ConsumerProducerAppConfiguration
extends Object

Configuration of a ConsumerProducerApp

Constructor Summary

Constructors

Constructor	Description
ConsumerProducerAppConfiguration(@NonNull ConsumerProducerTopicConfig topics, String uniqueAppId)
ConsumerProducerAppConfiguration(ConsumerProducerTopicConfig topics)	Create a new ConsumerAppConfiguration with no provided uniqueAppId

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

ConsumerProducerAppConfiguration

public ConsumerProducerAppConfiguration(ConsumerProducerTopicConfig topics)

Create a new ConsumerAppConfiguration with no provided uniqueAppId

Parameters:

topics - topics to use for app

ConsumerProducerAppConfiguration

public ConsumerProducerAppConfiguration(@NonNull
 @NonNull ConsumerProducerTopicConfig topics,
 String uniqueAppId)

Method Details

getUniqueAppId

public Optional<String> getUniqueAppId()

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

Returns:

provided unique group ID

See Also:

• ConsumerProducerApp.getUniqueAppId(ConsumerProducerAppConfiguration)

getTopics

@NonNull
public @NonNull ConsumerProducerTopicConfig getTopics()