Package com.adaptris.kafka

Interface ConfigBuilder

All Known Subinterfaces:

ConsumerConfigBuilder, ProducerConfigBuilder

All Known Implementing Classes:

AdvancedConfigBuilder, AdvancedConsumerConfigBuilder, AdvancedProducerConfigBuilder, BasicConsumerConfigBuilder, BasicProducerConfigBuilder, ConfigBuilderImpl, SimpleConfigBuilder

public interface ConfigBuilder

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	ConfigBuilder.Acks
static class	ConfigBuilder.CompressionType
static interface	ConfigBuilder.KeyFilter	For building a filtered Kafka configuration generally one or more of the keys defined in org.apache.kafka.clients.consumer.ConsumerConfig#configNames() or org.apache.kafka.clients.producer.ProducerConfig#configNames().

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	DEFAULT_KEY_DESERIALIZER
static java.lang.String	DEFAULT_KEY_SERIALIZER
static java.lang.String	DEFAULT_VALUE_DESERIALIZER
static java.lang.String	DEFAULT_VALUE_SERIALIZER
static java.lang.String	KEY_DESERIALIZER_FACTORY_CONFIG

Method Summary

Modifier and Type	Method	Description
java.util.Map<java.lang.String,java.lang.Object>	build()	Build a configuration suitable for both a consumer and producer.
java.util.Map<java.lang.String,java.lang.Object>	build(ConfigBuilder.KeyFilter t)	Build a configuration with a filter applied to the config names.

Field Detail

DEFAULT_KEY_SERIALIZER

static final java.lang.String DEFAULT_KEY_SERIALIZER

DEFAULT_VALUE_SERIALIZER

static final java.lang.String DEFAULT_VALUE_SERIALIZER

DEFAULT_KEY_DESERIALIZER

static final java.lang.String DEFAULT_KEY_DESERIALIZER

DEFAULT_VALUE_DESERIALIZER

static final java.lang.String DEFAULT_VALUE_DESERIALIZER

KEY_DESERIALIZER_FACTORY_CONFIG

static final java.lang.String KEY_DESERIALIZER_FACTORY_CONFIG

See Also:

Constant Field Values

Method Detail

build

java.util.Map<java.lang.String,java.lang.Object> build()
                                                      throws CoreException

Build a configuration suitable for both a consumer and producer.

Returns:

the configuration

Throws:

CoreException - wrapping any underlying exception.

build

java.util.Map<java.lang.String,java.lang.Object> build(ConfigBuilder.KeyFilter t)
                                                      throws CoreException

Build a configuration with a filter applied to the config names.

Parameters:

t - the keys to keep.

Returns:

the configuration

Throws:

CoreException - wrapping any underlying exception.

See Also:

ConfigDefinition