Package com.bakdata.kafka.producer

Class ProducerBuilder

java.lang.Object

com.bakdata.kafka.producer.ProducerBuilder

public final class ProducerBuilder
extends Object

Provides all runtime configurations when running a ProducerApp

See Also:

• ProducerApp.buildRunnable(ProducerBuilder)

Constructor Summary

Constructors

Constructor	Description
ProducerBuilder(@NonNull ProducerTopicConfig topics, @NonNull Map<String,Object> kafkaProperties)

Method Summary

Modifier and Type	Method	Description
AppConfiguration<ProducerTopicConfig>	createConfiguration()	Create AppConfiguration used by this app
com.bakdata.kafka.Configurator	createConfigurator()	Create Configurator to configure Serde and Serializer using kafkaProperties.
<K, V> org.apache.kafka.clients.producer.Producer<K,V>	createProducer()	Create a new Producer using kafkaProperties
<K, V> org.apache.kafka.clients.producer.Producer<K,V>	createProducer(org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)	Create a new Producer using kafkaProperties and provided Serializers
boolean	equals(Object o)
@NonNull Map<String,Object>	getKafkaProperties()
@NonNull ProducerTopicConfig	getTopics()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ProducerBuilder

public ProducerBuilder(@NonNull
 @NonNull ProducerTopicConfig topics,
 @NonNull
 @NonNull Map<String,Object> kafkaProperties)

Method Details

createProducer

public <K,
V>
org.apache.kafka.clients.producer.Producer<K,V> createProducer()

Create a new Producer using kafkaProperties

Type Parameters:

K - type of keys

V - type of values

Returns:

Producer

See Also:

• KafkaProducer(Map)

createProducer

public <K,
V>
org.apache.kafka.clients.producer.Producer<K,V> createProducer(org.apache.kafka.common.serialization.Serializer<K> keySerializer,
 org.apache.kafka.common.serialization.Serializer<V> valueSerializer)

Create a new Producer using kafkaProperties and provided Serializers

Type Parameters:

K - type of keys

V - type of values

Parameters:

keySerializer - Serializer to use for keys

valueSerializer - Serializer to use for values

Returns:

Producer

See Also:

• KafkaProducer(Map, Serializer, Serializer)

createConfigurator

public com.bakdata.kafka.Configurator createConfigurator()

Create Configurator to configure Serde and Serializer using kafkaProperties.

Returns:

Configurator

createConfiguration

public AppConfiguration<ProducerTopicConfig> createConfiguration()

Create AppConfiguration used by this app

Returns:

AppConfiguration

getTopics

@NonNull
public @NonNull ProducerTopicConfig getTopics()

getKafkaProperties

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

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object