Package com.bakdata.kafka.consumer

Class ConsumerAppConfiguration

java.lang.Object

com.bakdata.kafka.consumer.ConsumerAppConfiguration

public class ConsumerAppConfiguration
extends Object

Configuration of a ConsumerApp

Constructor Summary

Constructors

Constructor	Description
ConsumerAppConfiguration(@NonNull ConsumerTopicConfig topics, String uniqueGroupId)
ConsumerAppConfiguration(ConsumerTopicConfig topics)	Create a new ConsumerAppConfiguration with no provided uniqueGroupId

Method Summary

Modifier and Type	Method	Description
@NonNull ConsumerTopicConfig	getTopics()
Optional<String>	getUniqueGroupId()	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

ConsumerAppConfiguration

public ConsumerAppConfiguration(ConsumerTopicConfig topics)

Create a new ConsumerAppConfiguration with no provided uniqueGroupId

Parameters:

topics - topics to use for app

ConsumerAppConfiguration

public ConsumerAppConfiguration(@NonNull
 @NonNull ConsumerTopicConfig topics,
 String uniqueGroupId)

Method Details

getUniqueGroupId

public Optional<String> getUniqueGroupId()

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:

• ConsumerApp.getUniqueGroupId(ConsumerAppConfiguration)

getTopics

@NonNull
public @NonNull ConsumerTopicConfig getTopics()