Package com.bakdata.kafka

Class AppConfiguration<T>

java.lang.Object

com.bakdata.kafka.AppConfiguration<T>

Type Parameters:

T - type of topic config

public final class AppConfiguration<T>
extends Object

Configuration for setting up an app

See Also:

• App.setup(AppConfiguration)
• StreamsApp.setupCleanUp(AppConfiguration)
• App.setup(AppConfiguration)
• ProducerApp.setupCleanUp(AppConfiguration)

Constructor Summary

Constructors

Constructor	Description
AppConfiguration(T topics, @NonNull Map<String,Object> kafkaProperties)

Method Summary

Modifier and Type	Method	Description
AdminClientX	createAdminClient()	Create a new AdminClientX using kafkaProperties
boolean	equals(Object o)
@NonNull Map<String,Object>	getKafkaProperties()
T	getTopics()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

AppConfiguration

public AppConfiguration(@NonNull
 T topics,
 @NonNull
 @NonNull Map<String,Object> kafkaProperties)

Method Details

createAdminClient

public AdminClientX createAdminClient()

Create a new AdminClientX using kafkaProperties

Returns:

AdminClientX

getTopics

@NonNull
public T getTopics()

getKafkaProperties

@NonNull
public @NonNull Map<String,Object> getKafkaProperties()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object