io.simplesource.kafka.dsl

Class KafkaConfig

java.lang.Object

io.simplesource.kafka.dsl.KafkaConfig

public class KafkaConfig
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaConfig.Builder

Constructor Summary

Constructors

Constructor and Description
KafkaConfig()

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	adminClientConfig()
String	applicationId()
String	bootstrapServers()
Map<String,Object>	consumerConfig()
boolean	isExactlyOnce()
Map<String,Object>	producerConfig()
String	stateDir()
Map<String,Object>	streamsConfig()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaConfig

public KafkaConfig()

Method Detail

applicationId

public String applicationId()

bootstrapServers

public String bootstrapServers()

stateDir

public String stateDir()

isExactlyOnce

public boolean isExactlyOnce()

adminClientConfig

public Map<String,Object> adminClientConfig()

consumerConfig

public Map<String,Object> consumerConfig()

producerConfig

public Map<String,Object> producerConfig()

streamsConfig

public Map<String,Object> streamsConfig()