A B C D E F G I K L M N P R S V W
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() and ConfigDefinition.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() or org.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() with key.deserializer and value.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 create KafkaConsumer 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 uses MimeEncoder.

MimeEncoderDeserializer() - Constructor for class com.adaptris.kafka.MimeEncoderDeserializer

MimeEncoderSerializer - Class in com.adaptris.kafka

Serializer implementation for AdaptrisMessage objects that uses MimeEncoder

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 via Password.decode(String) and externally resolved via ExternalResolver.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() with key.serializer and value.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 with KafkaConnection.

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

A B C D E F G I K L M N P R S V W
All Classes All Packages