Package com.adaptris.kafka
Class ConfigDefinition
- java.lang.Object
-
- com.adaptris.kafka.ConfigDefinition
-
public class ConfigDefinition extends java.lang.Object
Helper for building a filtered Kafka configuration.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ConfigDefinition.FilterKeys
Wraps the static methods as an enum.
-
Constructor Summary
Constructors Constructor Description ConfigDefinition()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static ConfigBuilder.KeyFilter
both()
Union of bothproducer()
andconsumer()
.static ConfigBuilder.KeyFilter
consumer()
org.apache.kafka.clients.consumer.ConsumerConfig#configNames()
withkey.deserializer
andvalue.deserializer
static ConfigBuilder.KeyFilter
producer()
org.apache.kafka.clients.producer.ProducerConfig#configNames()
withkey.serializer
andvalue.serializer
-
-
-
Method Detail
-
producer
public static ConfigBuilder.KeyFilter producer()
org.apache.kafka.clients.producer.ProducerConfig#configNames()
withkey.serializer
andvalue.serializer
-
consumer
public static ConfigBuilder.KeyFilter consumer()
org.apache.kafka.clients.consumer.ConsumerConfig#configNames()
withkey.deserializer
andvalue.deserializer
-
both
public static ConfigBuilder.KeyFilter both()
Union of bothproducer()
andconsumer()
.
-
-