org.seedstack.kafka

Class KafkaConfig

java.lang.Object

org.seedstack.kafka.KafkaConfig

@Config(value="kafka")
public class KafkaConfig
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaConfig.ClientConfig
static class	KafkaConfig.ProducerConfig

Constructor Summary

Constructors

Constructor and Description
KafkaConfig()

Method Summary

Modifier and Type	Method and Description
KafkaConfig	addConsumer(String name, KafkaConfig.ClientConfig clientConfig)
KafkaConfig	addProducer(String name, KafkaConfig.ProducerConfig producerConfig)
KafkaConfig	addStream(String name, KafkaConfig.ClientConfig clientConfig)
Map<String,KafkaConfig.ClientConfig>	getConsumers()
Map<String,KafkaConfig.ProducerConfig>	getProducers()
Map<String,KafkaConfig.ClientConfig>	getStreams()

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

getConsumers

public Map<String,KafkaConfig.ClientConfig> getConsumers()

getProducers

public Map<String,KafkaConfig.ProducerConfig> getProducers()

getStreams

public Map<String,KafkaConfig.ClientConfig> getStreams()

addConsumer

public KafkaConfig addConsumer(String name,
                               KafkaConfig.ClientConfig clientConfig)

addProducer

public KafkaConfig addProducer(String name,
                               KafkaConfig.ProducerConfig producerConfig)

addStream

public KafkaConfig addStream(String name,
                             KafkaConfig.ClientConfig clientConfig)