A B C D E F G I K L M N P R S V W
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- AdaptrisMessageDeserializer - Class in com.adaptris.kafka
-
Deserializer implementation for
AdaptrisMessage
objects. - AdaptrisMessageDeserializer() - Constructor for class com.adaptris.kafka.AdaptrisMessageDeserializer
- AdaptrisMessageSerializer - Class in com.adaptris.kafka
-
Serializer implementation for
AdaptrisMessage
objects. - AdaptrisMessageSerializer() - Constructor for class com.adaptris.kafka.AdaptrisMessageSerializer
- addEntry(Map<String, Object>, String, Object) - Static method in class com.adaptris.kafka.ConfigBuilderImpl
- additionalDebug() - Method in interface com.adaptris.kafka.LoggingContext
- additionalDebug() - Method in class com.adaptris.kafka.PollingKafkaConsumer
- additionalDebug() - Method in class com.adaptris.kafka.StandardKafkaConsumer
- AdvancedConfigBuilder - Class in com.adaptris.kafka
-
Implementation of
ConfigBuilder
that exposes all configuration. - AdvancedConfigBuilder() - Constructor for class com.adaptris.kafka.AdvancedConfigBuilder
- AdvancedConfigBuilder(KeyValuePairSet) - Constructor for class com.adaptris.kafka.AdvancedConfigBuilder
- AdvancedConsumerConfigBuilder - Class in com.adaptris.kafka
-
Implementation of
ConsumerConfigBuilder
that exposes all configuration. - AdvancedConsumerConfigBuilder() - Constructor for class com.adaptris.kafka.AdvancedConsumerConfigBuilder
- AdvancedConsumerConfigBuilder(KeyValuePairSet) - Constructor for class com.adaptris.kafka.AdvancedConsumerConfigBuilder
- AdvancedProducerConfigBuilder - Class in com.adaptris.kafka
-
Deprecated.since 3.8.0 when using a
KafkaConnection
; has no meaning. - AdvancedProducerConfigBuilder() - Constructor for class com.adaptris.kafka.AdvancedProducerConfigBuilder
-
Deprecated.
- AdvancedProducerConfigBuilder(KeyValuePairSet) - Constructor for class com.adaptris.kafka.AdvancedProducerConfigBuilder
-
Deprecated.
- all - com.adaptris.kafka.ConfigBuilder.Acks
-
Equivalent to
all
.
B
- BasicConsumerConfigBuilder - Class in com.adaptris.kafka
-
Basic implementation of
ConsumerConfigBuilder
. - BasicConsumerConfigBuilder() - Constructor for class com.adaptris.kafka.BasicConsumerConfigBuilder
- BasicConsumerConfigBuilder(String) - Constructor for class com.adaptris.kafka.BasicConsumerConfigBuilder
- BasicConsumerConfigBuilder(String, String) - Constructor for class com.adaptris.kafka.BasicConsumerConfigBuilder
- BasicProducerConfigBuilder - Class in com.adaptris.kafka
-
Deprecated.since 3.8.0 when using a
KafkaConnection
; has no meaning. - BasicProducerConfigBuilder() - Constructor for class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.
- BasicProducerConfigBuilder(String) - Constructor for class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.
- both() - Static method in class com.adaptris.kafka.ConfigDefinition
-
Union of both
ConfigDefinition.producer()
andConfigDefinition.consumer()
. - build() - Method in class com.adaptris.kafka.AdvancedConfigBuilder
- build() - Method in interface com.adaptris.kafka.ConfigBuilder
-
Build a configuration suitable for both a consumer and producer.
- build() - Method in interface com.adaptris.kafka.ConsumerConfigBuilder
- build() - Method in interface com.adaptris.kafka.ProducerConfigBuilder
- build() - Method in class com.adaptris.kafka.SimpleConfigBuilder
- build(ConfigBuilder.KeyFilter) - Method in class com.adaptris.kafka.AdvancedConfigBuilder
- build(ConfigBuilder.KeyFilter) - Method in class com.adaptris.kafka.BasicConsumerConfigBuilder
- build(ConfigBuilder.KeyFilter) - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.
- build(ConfigBuilder.KeyFilter) - Method in interface com.adaptris.kafka.ConfigBuilder
-
Build a configuration with a filter applied to the config names.
- build(ConfigBuilder.KeyFilter) - Method in class com.adaptris.kafka.SimpleConfigBuilder
- buildConfig(ConfigBuilder.KeyFilter) - Method in class com.adaptris.kafka.KafkaConnection
C
- close() - Method in class com.adaptris.kafka.AdaptrisMessageDeserializer
- close() - Method in class com.adaptris.kafka.AdaptrisMessageSerializer
- close() - Method in class com.adaptris.kafka.PollingKafkaConsumer
- close() - Method in class com.adaptris.kafka.StandardKafkaConsumer
- close() - Method in class com.adaptris.kafka.StandardKafkaProducer
- com.adaptris.kafka - package com.adaptris.kafka
-
Consumer and producer implementations for Apache Kafka.
- ConfigBuilder - Interface in com.adaptris.kafka
- ConfigBuilder.Acks - Enum in com.adaptris.kafka
- ConfigBuilder.CompressionType - Enum in com.adaptris.kafka
- ConfigBuilder.KeyFilter - Interface in com.adaptris.kafka
-
For building a filtered Kafka configuration generally one or more of the keys defined in
org.apache.kafka.clients.consumer.ConsumerConfig#configNames()
ororg.apache.kafka.clients.producer.ProducerConfig#configNames()
. - ConfigBuilderImpl - Class in com.adaptris.kafka
- ConfigBuilderImpl() - Constructor for class com.adaptris.kafka.ConfigBuilderImpl
- ConfigDefinition - Class in com.adaptris.kafka
-
Helper for building a filtered Kafka configuration.
- ConfigDefinition() - Constructor for class com.adaptris.kafka.ConfigDefinition
- ConfigDefinition.FilterKeys - Enum in com.adaptris.kafka
-
Wraps the static methods as an enum.
- configFromConnection - Variable in class com.adaptris.kafka.StandardKafkaProducer
- configure(Map<String, ?>, boolean) - Method in class com.adaptris.kafka.AdaptrisMessageDeserializer
- configure(Map<String, ?>, boolean) - Method in class com.adaptris.kafka.AdaptrisMessageSerializer
- configure(Map<String, ?>, boolean) - Method in class com.adaptris.kafka.MimeEncoderDeserializer
- configure(Map<String, ?>, boolean) - Method in class com.adaptris.kafka.MimeEncoderSerializer
- consumer() - Static method in class com.adaptris.kafka.ConfigDefinition
-
org.apache.kafka.clients.consumer.ConsumerConfig#configNames()
withkey.deserializer
andvalue.deserializer
- Consumer - com.adaptris.kafka.ConfigDefinition.FilterKeys
- ConsumerConfigBuilder - Interface in com.adaptris.kafka
- createProducer(Map<String, Object>) - Method in class com.adaptris.kafka.StandardKafkaProducer
- createProducerRecord(String, String, AdaptrisMessage) - Method in class com.adaptris.kafka.PartitionedKafkaProducer
- createProducerRecord(String, String, AdaptrisMessage) - Method in class com.adaptris.kafka.StandardKafkaProducer
D
- DEFAULT_KEY_DESERIALIZER - Static variable in interface com.adaptris.kafka.ConfigBuilder
- DEFAULT_KEY_SERIALIZER - Static variable in interface com.adaptris.kafka.ConfigBuilder
- DEFAULT_VALUE_DESERIALIZER - Static variable in interface com.adaptris.kafka.ConfigBuilder
- DEFAULT_VALUE_SERIALIZER - Static variable in interface com.adaptris.kafka.ConfigBuilder
- deserialize(String, byte[]) - Method in class com.adaptris.kafka.AdaptrisMessageDeserializer
- deserialize(String, byte[]) - Method in class com.adaptris.kafka.MimeEncoderDeserializer
- doProduce(AdaptrisMessage, String) - Method in class com.adaptris.kafka.StandardKafkaProducer
E
- endpoint(AdaptrisMessage) - Method in class com.adaptris.kafka.StandardKafkaProducer
F
- factory - Variable in class com.adaptris.kafka.AdaptrisMessageDeserializer
G
- getAcks() - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.
- getAcks() - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
acks
property. - getAdditionalDebug() - Method in class com.adaptris.kafka.PollingKafkaConsumer
-
Whether or not to log all stacktraces.
- getAdditionalDebug() - Method in class com.adaptris.kafka.StandardKafkaConsumer
-
Whether or not to log all stacktraces.
- getBootstrapServers() - Method in class com.adaptris.kafka.BasicConsumerConfigBuilder
-
Set the
bootstrap.servers
property. - getBootstrapServers() - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.
- getBootstrapServers() - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
bootstrap.servers
property. - getBufferMemory() - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.
- getBufferMemory() - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
buffer.memory
property. - getCompressionType() - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.
- getCompressionType() - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
compression.type
property. - getConfig() - Method in class com.adaptris.kafka.AdvancedConfigBuilder
- getConfigBuilder() - Method in class com.adaptris.kafka.KafkaConnection
- getConsumerConfig() - Method in class com.adaptris.kafka.PollingKafkaConsumer
-
Configuration builder for this consumer
- getGroupId() - Method in class com.adaptris.kafka.BasicConsumerConfigBuilder
-
Set the
group.id
property. - getGroupId() - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
group.id
property. - getPartition() - Method in class com.adaptris.kafka.PartitionedKafkaProducer
-
Set the partition.
- getProducerConfig() - Method in class com.adaptris.kafka.StandardKafkaProducer
-
Deprecated.since 3.7.0 use a
KafkaConnection
instead. - getReceiveTimeout() - Method in class com.adaptris.kafka.PollingKafkaConsumer
-
Set the receive timeout.
- getRecordKey() - Method in class com.adaptris.kafka.StandardKafkaProducer
- getRetries() - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.
- getRetries() - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
retries
property. - getTopic() - Method in class com.adaptris.kafka.StandardKafkaProducer
-
The Kafka Topic to produce to
- getTopics() - Method in class com.adaptris.kafka.PollingKafkaConsumer
-
A comma separated list of topics that you want to consume from.
- getTopics() - Method in class com.adaptris.kafka.StandardKafkaConsumer
-
A comma separated list of topics that you want to consume from.
- gzip - com.adaptris.kafka.ConfigBuilder.CompressionType
-
Equivalent to
gzip
when specifying the compression type
I
- init() - Method in class com.adaptris.kafka.StandardKafkaConsumer
- init() - Method in class com.adaptris.kafka.StandardKafkaProducer
K
- KAFKA_TOPIC_KEY - Static variable in class com.adaptris.kafka.AdaptrisMessageDeserializer
-
The metadata key that will store the topic.
- KafkaConnection - Class in com.adaptris.kafka
-
Wraps the
Map<String,Object>
object used to createKafkaConsumer
KafkaProducer
instances. - KafkaConnection() - Constructor for class com.adaptris.kafka.KafkaConnection
- KafkaConnection(ConfigBuilder) - Constructor for class com.adaptris.kafka.KafkaConnection
- KEY_DESERIALIZER_FACTORY_CONFIG - Static variable in interface com.adaptris.kafka.ConfigBuilder
L
- local - com.adaptris.kafka.ConfigBuilder.Acks
-
Equivalent to
1
when specifying the number of acks. - log - Variable in class com.adaptris.kafka.AdvancedConfigBuilder
- log - Variable in class com.adaptris.kafka.ConfigBuilderImpl
- logger() - Method in interface com.adaptris.kafka.LoggingContext
- logger() - Method in class com.adaptris.kafka.PollingKafkaConsumer
- logger() - Method in class com.adaptris.kafka.StandardKafkaConsumer
- LOGGER - Static variable in interface com.adaptris.kafka.LoggingContext
- LoggingContext - Interface in com.adaptris.kafka
- lz4 - com.adaptris.kafka.ConfigBuilder.CompressionType
-
Equivalent to
lz4
when specifying the compression type
M
- MimeEncoderDeserializer - Class in com.adaptris.kafka
-
Deserializer implementation for
AdaptrisMessage
objects that usesMimeEncoder
. - MimeEncoderDeserializer() - Constructor for class com.adaptris.kafka.MimeEncoderDeserializer
- MimeEncoderSerializer - Class in com.adaptris.kafka
-
Serializer implementation for
AdaptrisMessage
objects that usesMimeEncoder
- MimeEncoderSerializer() - Constructor for class com.adaptris.kafka.MimeEncoderSerializer
N
- newThreadName() - Method in class com.adaptris.kafka.PollingKafkaConsumer
- newThreadName() - Method in class com.adaptris.kafka.StandardKafkaConsumer
- none - com.adaptris.kafka.ConfigBuilder.Acks
-
Equivalent to
0
when specifying the number of acks. - none - com.adaptris.kafka.ConfigBuilder.CompressionType
-
Equivalent to
none
when specifying the compression type
P
- PartitionedKafkaProducer - Class in com.adaptris.kafka
-
Extension of
StandardKafkaProducer
that allows you to specify a partition. - PartitionedKafkaProducer() - Constructor for class com.adaptris.kafka.PartitionedKafkaProducer
- PartitionedKafkaProducer(String, String) - Constructor for class com.adaptris.kafka.PartitionedKafkaProducer
- PASSWORD_KEYS - Static variable in class com.adaptris.kafka.AdvancedConfigBuilder
-
List of keys that can be
encoded
viaPassword.decode(String)
and externally resolved viaExternalResolver.resolve(String)
. - PollingKafkaConsumer - Class in com.adaptris.kafka
-
Wrapper around
KafkaConsumer
. - PollingKafkaConsumer() - Constructor for class com.adaptris.kafka.PollingKafkaConsumer
- PollingKafkaConsumer(ConsumerConfigBuilder) - Constructor for class com.adaptris.kafka.PollingKafkaConsumer
- prepare() - Method in class com.adaptris.kafka.StandardKafkaConsumer
- prepare() - Method in class com.adaptris.kafka.StandardKafkaProducer
- prepareConsumer() - Method in class com.adaptris.kafka.PollingKafkaConsumer
- processMessages() - Method in class com.adaptris.kafka.PollingKafkaConsumer
- producer - Variable in class com.adaptris.kafka.StandardKafkaProducer
- producer() - Static method in class com.adaptris.kafka.ConfigDefinition
-
org.apache.kafka.clients.producer.ProducerConfig#configNames()
withkey.serializer
andvalue.serializer
- Producer - com.adaptris.kafka.ConfigDefinition.FilterKeys
- ProducerConfigBuilder - Interface in com.adaptris.kafka
- ProducerOrConsumer - com.adaptris.kafka.ConfigDefinition.FilterKeys
R
- registerConnection(AdaptrisConnection) - Method in class com.adaptris.kafka.StandardKafkaProducer
- retainKeys() - Method in interface com.adaptris.kafka.ConfigBuilder.KeyFilter
- retainKeys() - Method in enum com.adaptris.kafka.ConfigDefinition.FilterKeys
S
- serialize(String, AdaptrisMessage) - Method in class com.adaptris.kafka.AdaptrisMessageSerializer
- serialize(String, AdaptrisMessage) - Method in class com.adaptris.kafka.MimeEncoderSerializer
- setAcks(ConfigBuilder.Acks) - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.Set the
acks
property. - setAcks(ConfigBuilder.Acks) - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
acks
property. - setAdditionalDebug(Boolean) - Method in class com.adaptris.kafka.PollingKafkaConsumer
-
Whether or not to log all stacktraces.
- setAdditionalDebug(Boolean) - Method in class com.adaptris.kafka.StandardKafkaConsumer
-
Whether or not to log all stacktraces.
- setBootstrapServers(String) - Method in class com.adaptris.kafka.BasicConsumerConfigBuilder
-
Set the
bootstrap.servers
property. - setBootstrapServers(String) - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
bootstrap.servers
property. - setBootstrapServers(String) - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.Set the
bootstrap.servers
property. - setBufferMemory(Long) - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.Set the
buffer.memory
property. - setBufferMemory(Long) - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
buffer.memory
property. - setCompressionType(ConfigBuilder.CompressionType) - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.Set the
compression.type
property. - setCompressionType(ConfigBuilder.CompressionType) - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
compression.type
property. - setConfig(KeyValuePairSet) - Method in class com.adaptris.kafka.AdvancedConfigBuilder
- setConfigBuilder(ConfigBuilder) - Method in class com.adaptris.kafka.KafkaConnection
- setConsumerConfig(ConsumerConfigBuilder) - Method in class com.adaptris.kafka.PollingKafkaConsumer
-
Configuration builder for this consumer
- setGroupId(String) - Method in class com.adaptris.kafka.BasicConsumerConfigBuilder
-
Set the
group.id
property. - setGroupId(String) - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
group.id
property. - setPartition(String) - Method in class com.adaptris.kafka.PartitionedKafkaProducer
-
Set the partition.
- setProducerConfig(ProducerConfigBuilder) - Method in class com.adaptris.kafka.StandardKafkaProducer
-
Deprecated.since 3.7.0 use a
KafkaConnection
instead. - setReceiveTimeout(TimeInterval) - Method in class com.adaptris.kafka.PollingKafkaConsumer
-
Set the receive timeout.
- setRecordKey(String) - Method in class com.adaptris.kafka.StandardKafkaProducer
-
Set the key for the generated
ProducerRecord
. - setRetries(Integer) - Method in class com.adaptris.kafka.BasicProducerConfigBuilder
-
Deprecated.Set the
retries
property. - setRetries(Integer) - Method in class com.adaptris.kafka.SimpleConfigBuilder
-
Set the
retries
property. - setTopic(String) - Method in class com.adaptris.kafka.StandardKafkaProducer
-
The Kafka Topic to produce to
- setTopics(String) - Method in class com.adaptris.kafka.PollingKafkaConsumer
-
A comma separated list of topics that you want to consume from.
- setTopics(String) - Method in class com.adaptris.kafka.StandardKafkaConsumer
-
A comma separated list of topics that you want to consume from.
- SimpleConfigBuilder - Class in com.adaptris.kafka
-
Simple implementation of
ConfigBuilder
for use withKafkaConnection
. - SimpleConfigBuilder() - Constructor for class com.adaptris.kafka.SimpleConfigBuilder
- SimpleConfigBuilder(String) - Constructor for class com.adaptris.kafka.SimpleConfigBuilder
- snappy - com.adaptris.kafka.ConfigBuilder.CompressionType
-
Equivalent to
snappy
when specifying the compression type - StandardKafkaConsumer - Class in com.adaptris.kafka
-
Wrapper around
KafkaConsumer
. - StandardKafkaConsumer() - Constructor for class com.adaptris.kafka.StandardKafkaConsumer
- StandardKafkaProducer - Class in com.adaptris.kafka
-
Wrapper around
KafkaProducer
. - StandardKafkaProducer() - Constructor for class com.adaptris.kafka.StandardKafkaProducer
- StandardKafkaProducer(String, String) - Constructor for class com.adaptris.kafka.StandardKafkaProducer
- start() - Method in class com.adaptris.kafka.PollingKafkaConsumer
- start() - Method in class com.adaptris.kafka.StandardKafkaConsumer
- start() - Method in class com.adaptris.kafka.StandardKafkaProducer
- stop() - Method in class com.adaptris.kafka.PollingKafkaConsumer
- stop() - Method in class com.adaptris.kafka.StandardKafkaConsumer
- stop() - Method in class com.adaptris.kafka.StandardKafkaProducer
V
- valueOf(String) - Static method in enum com.adaptris.kafka.ConfigBuilder.Acks
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.adaptris.kafka.ConfigBuilder.CompressionType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.adaptris.kafka.ConfigDefinition.FilterKeys
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum com.adaptris.kafka.ConfigBuilder.Acks
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum com.adaptris.kafka.ConfigBuilder.CompressionType
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum com.adaptris.kafka.ConfigDefinition.FilterKeys
-
Returns an array containing the constants of this enum type, in the order they are declared.
W
- withPartition(String) - Method in class com.adaptris.kafka.PartitionedKafkaProducer
- withTopics(String) - Method in class com.adaptris.kafka.PollingKafkaConsumer
- withTopics(String) - Method in class com.adaptris.kafka.StandardKafkaConsumer
All Classes All Packages