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 in org.apache.kafka.clients.consumer.ConsumerConfig#configNames() or org.apache.kafka.clients.producer.ProducerConfig#configNames().
ConsumerConfigBuilder
LoggingContext
ProducerConfigBuilder

Class Summary

Class	Description
AdaptrisMessageDeserializer	Deserializer implementation for AdaptrisMessage objects.
AdaptrisMessageSerializer	Serializer implementation for AdaptrisMessage objects.
AdvancedConfigBuilder	Implementation of ConfigBuilder that exposes all configuration.
AdvancedConsumerConfigBuilder	Implementation of ConsumerConfigBuilder that exposes all configuration.
AdvancedProducerConfigBuilder	Deprecated. since 3.8.0 when using a KafkaConnection; has no meaning.
BasicConsumerConfigBuilder	Basic implementation of ConsumerConfigBuilder.
BasicProducerConfigBuilder	Deprecated. since 3.8.0 when using a KafkaConnection; has no meaning.
ConfigBuilderImpl
ConfigDefinition	Helper for building a filtered Kafka configuration.
KafkaConnection	Wraps the Map<String,Object> object used to create KafkaConsumer KafkaProducer instances.
MimeEncoderDeserializer	Deserializer implementation for AdaptrisMessage objects that uses MimeEncoder.
MimeEncoderSerializer	Serializer implementation for AdaptrisMessage objects that uses MimeEncoder
PartitionedKafkaProducer	Extension of StandardKafkaProducer that allows you to specify a partition.
PollingKafkaConsumer	Wrapper around KafkaConsumer.
SimpleConfigBuilder	Simple implementation of ConfigBuilder for use with KafkaConnection.
StandardKafkaConsumer	Wrapper around KafkaConsumer.
StandardKafkaProducer	Wrapper around KafkaProducer.

Enum Summary

Enum	Description
ConfigBuilder.Acks
ConfigBuilder.CompressionType
ConfigDefinition.FilterKeys	Wraps the static methods as an enum.