Package com.adaptris.kafka
Consumer and producer implementations for Apache Kafka.
-
Interface Summary Interface Description ConfigBuilder 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()
.ConsumerConfigBuilder LoggingContext ProducerConfigBuilder -
Class Summary Class Description AdaptrisMessageDeserializer Deserializer implementation forAdaptrisMessage
objects.AdaptrisMessageSerializer Serializer implementation forAdaptrisMessage
objects.AdvancedConfigBuilder Implementation ofConfigBuilder
that exposes all configuration.AdvancedConsumerConfigBuilder Implementation ofConsumerConfigBuilder
that exposes all configuration.AdvancedProducerConfigBuilder Deprecated. since 3.8.0 when using aKafkaConnection
; has no meaning.BasicConsumerConfigBuilder Basic implementation ofConsumerConfigBuilder
.BasicProducerConfigBuilder Deprecated. since 3.8.0 when using aKafkaConnection
; has no meaning.ConfigBuilderImpl ConfigDefinition Helper for building a filtered Kafka configuration.KafkaConnection Wraps theMap<String,Object>
object used to createKafkaConsumer
KafkaProducer
instances.MimeEncoderDeserializer Deserializer implementation forAdaptrisMessage
objects that usesMimeEncoder
.MimeEncoderSerializer Serializer implementation forAdaptrisMessage
objects that usesMimeEncoder
PartitionedKafkaProducer Extension ofStandardKafkaProducer
that allows you to specify a partition.PollingKafkaConsumer Wrapper aroundKafkaConsumer
.SimpleConfigBuilder Simple implementation ofConfigBuilder
for use withKafkaConnection
.StandardKafkaConsumer Wrapper aroundKafkaConsumer
.StandardKafkaProducer Wrapper aroundKafkaProducer
. -
Enum Summary Enum Description ConfigBuilder.Acks ConfigBuilder.CompressionType ConfigDefinition.FilterKeys Wraps the static methods as an enum.