io.simplesource.kafka.dsl

Class KafkaConfig.Builder

java.lang.Object

io.simplesource.kafka.dsl.KafkaConfig.Builder

Enclosing class:

KafkaConfig

public static class KafkaConfig.Builder
extends Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
KafkaConfig	build()
KafkaConfig	build(boolean clientOnly)
KafkaConfig.Builder	withAtLeastOnce()
KafkaConfig.Builder	withExactlyOnce()
KafkaConfig.Builder	withKafkaApplicationId(String applicationId)
KafkaConfig.Builder	withKafkaBootstrap(String bootstrapServers)
KafkaConfig.Builder	withSetting(String name, Object value)
KafkaConfig.Builder	withSettings(Map<String,Object> config)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

withKafkaApplicationId

public KafkaConfig.Builder withKafkaApplicationId(String applicationId)

withKafkaBootstrap

public KafkaConfig.Builder withKafkaBootstrap(String bootstrapServers)

withExactlyOnce

public KafkaConfig.Builder withExactlyOnce()

withAtLeastOnce

public KafkaConfig.Builder withAtLeastOnce()

withSetting

public KafkaConfig.Builder withSetting(String name,
                                       Object value)

withSettings

public KafkaConfig.Builder withSettings(Map<String,Object> config)

build

public KafkaConfig build()

build

public KafkaConfig build(boolean clientOnly)