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 inorg.apache.kafka.clients.consumer.ConsumerConfig#configNames()
ororg.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
All Methods Instance Methods Abstract Methods 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
-
-