Package com.bakdata.kafka.producer

Class ConfiguredProducerApp<T extends ProducerApp>

java.lang.Object

com.bakdata.kafka.producer.ConfiguredProducerApp<T>

Type Parameters:

T - type of ProducerApp

All Implemented Interfaces:

ConfiguredApp<ExecutableProducerApp<T>>, AutoCloseable

public class ConfiguredProducerApp<T extends ProducerApp>
extends Object
implements ConfiguredApp<ExecutableProducerApp<T>>

A ProducerApp with a corresponding ProducerAppConfiguration

Constructor Summary

Constructors

Constructor	Description
ConfiguredProducerApp(T app, @NonNull ProducerAppConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
void	close()
T	getApp()
Map<String,Object>	getKafkaProperties(RuntimeConfiguration runtimeConfiguration)	This method creates the configuration to run a ProducerApp.
ProducerTopicConfig	getTopics()	Get topic configuration
ExecutableProducerApp<T>	withRuntimeConfiguration(RuntimeConfiguration runtimeConfiguration)	Create an ExecutableProducerApp using the provided RuntimeConfiguration

Methods inherited from class java.lang.Object

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

Constructor Details

ConfiguredProducerApp

public ConfiguredProducerApp(@NonNull
 T app,
 @NonNull
 @NonNull ProducerAppConfiguration configuration)

Method Details

getKafkaProperties

public Map<String,Object> getKafkaProperties(RuntimeConfiguration runtimeConfiguration)

This method creates the configuration to run a ProducerApp.

Configuration is created in the following order

•  max.in.flight.requests.per.connection=1
   acks=all
   compression.type=gzip
   

• Configs provided by App.createKafkaProperties()
• Configs provided via environment variables (see EnvironmentKafkaConfigParser.parseVariables(Map))
• Configs provided by RuntimeConfiguration.createKafkaProperties()
• ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG and ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG is configured using ProducerApp.defaultSerializationConfig()

Parameters:

runtimeConfiguration - configuration to run app with

Returns:

Kafka configuration

withRuntimeConfiguration

public ExecutableProducerApp<T> withRuntimeConfiguration(RuntimeConfiguration runtimeConfiguration)

Create an ExecutableProducerApp using the provided RuntimeConfiguration

Specified by:

withRuntimeConfiguration in interface ConfiguredApp<T extends ProducerApp>

Parameters:

runtimeConfiguration - configuration to run app with

Returns:

ExecutableProducerApp

getTopics

public ProducerTopicConfig getTopics()

Get topic configuration

Returns:

topic configuration

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ConfiguredApp<T extends ProducerApp>

getApp

@NonNull
public T getApp()