A B C E F G H K L M N O P R S T V

A

assign(TopicPartition) - Method in interface net.researchgate.kafka.metamorph.PartitionConsumer

Manually assign a partition to this consumer.

B

BOOTSTRAP_SERVERS_CONFIG - Static variable in class net.researchgate.kafka.metamorph.CommonClientConfigs

BOOTSTRAP_SERVERS_CONFIG - Static variable in class net.researchgate.kafka.metamorph.ConsumerConfig

bootstrap.servers

C

close() - Method in interface net.researchgate.kafka.metamorph.PartitionConsumer

Close the consumer

CommonClientConfigs - Class in net.researchgate.kafka.metamorph

Some configurations shared by both producer and consumer

CommonClientConfigs() - Constructor for class net.researchgate.kafka.metamorph.CommonClientConfigs

ConsumerConfig - Class in net.researchgate.kafka.metamorph

The consumer configuration keys

ConsumerConfig() - Constructor for class net.researchgate.kafka.metamorph.ConsumerConfig

createConsumer(Properties, Object, Object) - Method in interface net.researchgate.kafka.metamorph.PartitionConsumerProvider

Creates consumer with key/value-decoder/deserializer instances passed.

createConsumer(Properties) - Method in interface net.researchgate.kafka.metamorph.PartitionConsumerProvider

E

earliestPosition() - Method in interface net.researchgate.kafka.metamorph.PartitionConsumer

Get the earliest offset for the assigned partition It is an error if the consumer is not assigned to a partition before invoking this method.

equals(Object) - Method in class net.researchgate.kafka.metamorph.KafkaNode

equals(Object) - Method in class net.researchgate.kafka.metamorph.TopicPartition

F

fromString(String) - Static method in class net.researchgate.kafka.metamorph.KafkaNode

A convenient factory method to create a KafkaNode from a string representation.

G

getAssignment() - Method in interface net.researchgate.kafka.metamorph.PartitionConsumer

Get currently assigned topic partition

getProvider() - Method in class net.researchgate.kafka.metamorph.PartitionConsumerFactory

Get implementation-specific provider which is able to create PartitionConsumer

H

hashCode() - Method in class net.researchgate.kafka.metamorph.KafkaNode

hashCode() - Method in class net.researchgate.kafka.metamorph.TopicPartition

host() - Method in class net.researchgate.kafka.metamorph.KafkaNode

K

KafkaNode - Class in net.researchgate.kafka.metamorph

A representation of a Kafka node

KafkaNode(String, int) - Constructor for class net.researchgate.kafka.metamorph.KafkaNode

key() - Method in class net.researchgate.kafka.metamorph.PartitionConsumerRecord

KEY_DESERIALIZER_CLASS_CONFIG - Static variable in class net.researchgate.kafka.metamorph.ConsumerConfig

key.deserializer

L

latestPosition() - Method in interface net.researchgate.kafka.metamorph.PartitionConsumer

Get the latest offset for the assigned partition It is an error if the consumer is not assigned to a partition before invoking this method.

M

MAX_PARTITION_FETCH_BYTES_CONFIG - Static variable in class net.researchgate.kafka.metamorph.ConsumerConfig

max.partition.fetch.bytes

N

net.researchgate.kafka.metamorph - package net.researchgate.kafka.metamorph

net.researchgate.kafka.metamorph.exceptions - package net.researchgate.kafka.metamorph.exceptions

O

offset() - Method in class net.researchgate.kafka.metamorph.PartitionConsumerRecord

P

partition() - Method in class net.researchgate.kafka.metamorph.PartitionConsumerRecord

partition() - Method in class net.researchgate.kafka.metamorph.TopicPartition

PartitionConsumer<K,V> - Interface in net.researchgate.kafka.metamorph

A Kafka consumer interface for consumption of a topic partition

PartitionConsumerException - Exception in net.researchgate.kafka.metamorph.exceptions

Base class of all consumer exceptions

PartitionConsumerException() - Constructor for exception net.researchgate.kafka.metamorph.exceptions.PartitionConsumerException

PartitionConsumerException(String) - Constructor for exception net.researchgate.kafka.metamorph.exceptions.PartitionConsumerException

PartitionConsumerException(String, Throwable) - Constructor for exception net.researchgate.kafka.metamorph.exceptions.PartitionConsumerException

PartitionConsumerException(Throwable) - Constructor for exception net.researchgate.kafka.metamorph.exceptions.PartitionConsumerException

PartitionConsumerFactory - Class in net.researchgate.kafka.metamorph

Implementation-agnostic factory for new PartitionConsumer instance creation.

PartitionConsumerFactory() - Constructor for class net.researchgate.kafka.metamorph.PartitionConsumerFactory

PartitionConsumerProvider - Interface in net.researchgate.kafka.metamorph

Interface to get configured instance of PartitionConsumer without explicit Kafka version specification.

PartitionConsumerRecord<K,V> - Class in net.researchgate.kafka.metamorph

A representation of a record which has been fetched from a specific topic and partition

PartitionConsumerRecord(String, int, K, V, long) - Constructor for class net.researchgate.kafka.metamorph.PartitionConsumerRecord

Creates a record to be received from a specified topic and partition

partitionsFor(String) - Method in interface net.researchgate.kafka.metamorph.PartitionConsumer

Get partitions for a given topic

poll(int) - Method in interface net.researchgate.kafka.metamorph.PartitionConsumer

Fetch data for the assigned partition.

port() - Method in class net.researchgate.kafka.metamorph.KafkaNode

position() - Method in interface net.researchgate.kafka.metamorph.PartitionConsumer

Get the offset of the next record that will be fetched for the assigned partition (if a record with that offset exists).

R

REQUEST_TIMEOUT_MS_CONFIG - Static variable in class net.researchgate.kafka.metamorph.CommonClientConfigs

REQUEST_TIMEOUT_MS_CONFIG - Static variable in class net.researchgate.kafka.metamorph.ConsumerConfig

request.timeout.ms

S

seek(long) - Method in interface net.researchgate.kafka.metamorph.PartitionConsumer

Explicitly sets the fetch offset which will be used on the next poll(timeout) It is an error if the consumer is not assigned to a partition before invoking this method.

T

topic() - Method in class net.researchgate.kafka.metamorph.PartitionConsumerRecord

topic() - Method in class net.researchgate.kafka.metamorph.TopicPartition

TopicPartition - Class in net.researchgate.kafka.metamorph

A representation of a Kafka topic and partition

TopicPartition(String, int) - Constructor for class net.researchgate.kafka.metamorph.TopicPartition

toString() - Method in class net.researchgate.kafka.metamorph.KafkaNode

toString() - Method in class net.researchgate.kafka.metamorph.TopicPartition

V

value() - Method in class net.researchgate.kafka.metamorph.PartitionConsumerRecord

VALUE_DESERIALIZER_CLASS_CONFIG - Static variable in class net.researchgate.kafka.metamorph.ConsumerConfig

value.deserializer

A B C E F G H K L M N O P R S T V