A B C D E F G H I J K L M N O P R S T U V W

A

addHeader(String, String) - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

Like KafkaProducerRecord.addHeader(KafkaHeader) but with a key/value pair

addHeader(String, Buffer) - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

Like KafkaProducerRecord.addHeader(KafkaHeader) but with a key/value pair

addHeader(KafkaHeader) - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

Add an header to this record.

addHeaders(List<KafkaHeader>) - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

Add a list of headers to this record.

AdminUtils - Interface in io.vertx.kafka.admin

Deprecated.

This class is now deprecated. @see io.vertx.kafka.admin.KafkaAdminClient instead.

alterConfigs(Map<ConfigResource, Config>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.admin.KafkaAdminClient

Update the configuration for the specified resources with the default options

assign(TopicPartition) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Manually assign a partition to this consumer.

assign(Set<TopicPartition>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Manually assign a list of partition to this consumer.

assign(TopicPartition, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Manually assign a partition to this consumer.

assign(Set<TopicPartition>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Manually assign a list of partition to this consumer.

assign(Set<TopicPartition>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Manually assign a set of partitions to this consumer.

assign(Set<TopicPartition>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Manually assign a set of partitions to this consumer.

assignment(Handler<AsyncResult<Set<TopicPartition>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Get the set of partitions currently assigned to this consumer.

assignment(Handler<AsyncResult<Set<TopicPartition>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Get the set of partitions currently assigned to this consumer.

asStream() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

asStream() - Method in interface io.vertx.kafka.client.producer.KafkaProducer

B

batchHandler(Handler<KafkaConsumerRecords<K, V>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Set the handler to be used when batches of messages are fetched from the Kafka server.

batchHandler(Handler<ConsumerRecords<K, V>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Set the handler that will be called when a new batch of records is returned from Kafka.

beginningOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Get the first offset for the given partitions.

beginningOffsets(TopicPartition, Handler<AsyncResult<Long>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Get the first offset for the given partitions.

beginningOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Get the first offset for the given partitions.

beginningOffsets(TopicPartition, Handler<AsyncResult<Long>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Get the first offset for the given partition.

Buffer() - Static method in class io.vertx.kafka.client.serialization.VertxSerdes

BufferDeserializer - Class in io.vertx.kafka.client.serialization

Kafka deserializer for raw bytes in a buffer

BufferDeserializer() - Constructor for class io.vertx.kafka.client.serialization.BufferDeserializer

BufferSerde() - Constructor for class io.vertx.kafka.client.serialization.VertxSerdes.BufferSerde

BufferSerializer - Class in io.vertx.kafka.client.serialization

Kafka serializer for raw bytes in a buffer

BufferSerializer() - Constructor for class io.vertx.kafka.client.serialization.BufferSerializer

C

changeTopicConfig(String, Map<String, String>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.admin.AdminUtils

Deprecated.

Updates the configuration of the topic given by topicName.

checksum() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecord

Deprecated.

As of Kafka 0.11.0. Because of the potential for message format conversion on the broker, the checksum returned by the broker may not match what was computed by the producer. It is therefore unsafe to depend on this checksum for end-to-end delivery guarantees. Additionally, message format v2 does not include a record-level checksum (for performance, the record checksum was replaced with a batch checksum). To maintain compatibility, a partial checksum computed from the record timestamp, serialized key size, and serialized value size is returned instead, but this should not be depended on for end-to-end reliability.

checksum() - Method in class io.vertx.kafka.client.producer.RecordMetadata

Deprecated.

As of Kafka 0.11.0. Because of the potential for message format conversion on the broker, the checksum returned by the broker may not match what was computed by the producer. It is therefore unsafe to depend on this checksum for end-to-end delivery guarantees. Additionally, message format v2 does not include a record-level checksum (for performance, the record checksum was replaced with a batch checksum). To maintain compatibility, a partial checksum computed from the record timestamp, serialized key size, and serialized value size is returned instead, but this should not be depended on for end-to-end reliability.

close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.admin.AdminUtils

Deprecated.

Closes the underlying connection to Zookeeper.

close() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Close the consumer

close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Close the consumer

close() - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Close the stream

close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Close the stream

close() - Method in interface io.vertx.kafka.client.producer.KafkaProducer

Close the producer

close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

Close the producer

close(long, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

Close the producer

close() - Method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Close the stream

close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Close the stream

close(long, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Close the stream

close() - Method in class io.vertx.kafka.client.serialization.BufferDeserializer

close() - Method in class io.vertx.kafka.client.serialization.BufferSerializer

close() - Method in class io.vertx.kafka.client.serialization.JsonArrayDeserializer

close() - Method in class io.vertx.kafka.client.serialization.JsonArraySerializer

close() - Method in class io.vertx.kafka.client.serialization.JsonObjectDeserializer

close() - Method in class io.vertx.kafka.client.serialization.JsonObjectSerializer

commit() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Commit current offsets for all the subscribed list of topics and partition.

commit(Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Commit current offsets for all the subscribed list of topics and partition.

commit(Map<TopicPartition, OffsetAndMetadata>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Commit the specified offsets for the specified list of topics and partitions to Kafka.

commit(Map<TopicPartition, OffsetAndMetadata>, Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Commit the specified offsets for the specified list of topics and partitions to Kafka.

commit() - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Commit current offsets for all the subscribed list of topics and partition.

commit(Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Commit current offsets for all the subscribed list of topics and partition.

commit(Map<TopicPartition, OffsetAndMetadata>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Commit the specified offsets for the specified list of topics and partitions to Kafka.

commit(Map<TopicPartition, OffsetAndMetadata>, Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Commit the specified offsets for the specified list of topics and partitions to Kafka.

committed(TopicPartition, Handler<AsyncResult<OffsetAndMetadata>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Get the last committed offset for the given partition (whether the commit happened by this process or another).

committed(TopicPartition, Handler<AsyncResult<OffsetAndMetadata>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Get the last committed offset for the given partition (whether the commit happened by this process or another).

Config - Class in io.vertx.kafka.admin

A configuration object containing the configuration entries for a resource

Config() - Constructor for class io.vertx.kafka.admin.Config

Constructor

Config(List<ConfigEntry>) - Constructor for class io.vertx.kafka.admin.Config

Constructor

Config(JsonObject) - Constructor for class io.vertx.kafka.admin.Config

Constructor (from JSON representation)

ConfigConverter - Class in io.vertx.kafka.admin

Converter for Config.

ConfigConverter() - Constructor for class io.vertx.kafka.admin.ConfigConverter

ConfigEntry - Class in io.vertx.kafka.admin

A class representing a configuration entry containing name, value and additional metadata

ConfigEntry() - Constructor for class io.vertx.kafka.admin.ConfigEntry

Constructor

ConfigEntry(String, String) - Constructor for class io.vertx.kafka.admin.ConfigEntry

Constructor

ConfigEntry(JsonObject) - Constructor for class io.vertx.kafka.admin.ConfigEntry

Constructor (from JSON representation)

ConfigEntryConverter - Class in io.vertx.kafka.admin

Converter for ConfigEntry.

ConfigEntryConverter() - Constructor for class io.vertx.kafka.admin.ConfigEntryConverter

ConfigResource - Class in io.vertx.kafka.client.common

A class representing resources that have configuration

ConfigResource() - Constructor for class io.vertx.kafka.client.common.ConfigResource

Constructor

ConfigResource(ConfigResource.Type, String) - Constructor for class io.vertx.kafka.client.common.ConfigResource

Constructor

ConfigResource(JsonObject) - Constructor for class io.vertx.kafka.client.common.ConfigResource

Constructor (from JSON representation)

ConfigResourceConverter - Class in io.vertx.kafka.client.common

Converter for ConfigResource.

ConfigResourceConverter() - Constructor for class io.vertx.kafka.client.common.ConfigResourceConverter

ConfigSynonym - Class in io.vertx.kafka.admin

Class representing a configuration synonym of a ConfigEntry

ConfigSynonym() - Constructor for class io.vertx.kafka.admin.ConfigSynonym

Constructor

ConfigSynonym(String, String, ConfigEntry.ConfigSource) - Constructor for class io.vertx.kafka.admin.ConfigSynonym

Constructor

ConfigSynonym(JsonObject) - Constructor for class io.vertx.kafka.admin.ConfigSynonym

Constructor (from JSON representation)

ConfigSynonymConverter - Class in io.vertx.kafka.admin

Converter for ConfigSynonym.

ConfigSynonymConverter() - Constructor for class io.vertx.kafka.admin.ConfigSynonymConverter

configure(Map<String, ?>, boolean) - Method in class io.vertx.kafka.client.serialization.BufferDeserializer

configure(Map<String, ?>, boolean) - Method in class io.vertx.kafka.client.serialization.BufferSerializer

configure(Map<String, ?>, boolean) - Method in class io.vertx.kafka.client.serialization.JsonArrayDeserializer

configure(Map<String, ?>, boolean) - Method in class io.vertx.kafka.client.serialization.JsonArraySerializer

configure(Map<String, ?>, boolean) - Method in class io.vertx.kafka.client.serialization.JsonObjectDeserializer

configure(Map<String, ?>, boolean) - Method in class io.vertx.kafka.client.serialization.JsonObjectSerializer

ConsumerGroupDescription - Class in io.vertx.kafka.admin

A detailed description of a single consumer group in the cluster

ConsumerGroupDescription() - Constructor for class io.vertx.kafka.admin.ConsumerGroupDescription

Constructor

ConsumerGroupDescription(String, boolean, List<MemberDescription>, String, ConsumerGroupState, Node) - Constructor for class io.vertx.kafka.admin.ConsumerGroupDescription

Constructor

ConsumerGroupDescription(JsonObject) - Constructor for class io.vertx.kafka.admin.ConsumerGroupDescription

Constructor (from JSON representation)

ConsumerGroupDescriptionConverter - Class in io.vertx.kafka.admin

Converter for ConsumerGroupDescription.

ConsumerGroupDescriptionConverter() - Constructor for class io.vertx.kafka.admin.ConsumerGroupDescriptionConverter

ConsumerGroupListing - Class in io.vertx.kafka.admin

A listing of a consumer group in the cluster.

ConsumerGroupListing() - Constructor for class io.vertx.kafka.admin.ConsumerGroupListing

Constructor

ConsumerGroupListing(String, boolean) - Constructor for class io.vertx.kafka.admin.ConsumerGroupListing

Constructor

ConsumerGroupListing(JsonObject) - Constructor for class io.vertx.kafka.admin.ConsumerGroupListing

Constructor (from JSON representation)

ConsumerGroupListingConverter - Class in io.vertx.kafka.admin

Converter for ConsumerGroupListing.

ConsumerGroupListingConverter() - Constructor for class io.vertx.kafka.admin.ConsumerGroupListingConverter

create(Vertx, String) - Static method in interface io.vertx.kafka.admin.AdminUtils

Deprecated.

Create a new AdminUtils instance

create(Vertx, String, boolean) - Static method in interface io.vertx.kafka.admin.AdminUtils

Deprecated.

Create a new AdminUtils instance

create(Vertx, String, int, boolean, boolean) - Static method in interface io.vertx.kafka.admin.AdminUtils

Deprecated.

Create a new AdminUtils instance

create(Vertx, AdminClient) - Static method in interface io.vertx.kafka.admin.KafkaAdminClient

Create a new KafkaAdminClient instance

create(Vertx, Map<String, String>) - Static method in interface io.vertx.kafka.admin.KafkaAdminClient

Create a new KafkaAdminClient instance

create(Vertx, Properties) - Static method in interface io.vertx.kafka.admin.KafkaAdminClient

Create a new KafkaAdminClient instance

create(Vertx, Consumer<K, V>) - Static method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Create a new KafkaConsumer instance from a native Consumer.

create(Vertx, Map<String, String>) - Static method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Create a new KafkaConsumer instance

create(Vertx, Map<String, String>, Class<K>, Class<V>) - Static method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Create a new KafkaConsumer instance

create(Vertx, Map<String, String>, Deserializer<K>, Deserializer<V>) - Static method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Create a new KafkaConsumer instance

create(Vertx, Properties) - Static method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Create a new KafkaConsumer instance

create(Vertx, Properties, Class<K>, Class<V>) - Static method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Create a new KafkaConsumer instance

create(Vertx, Properties, Deserializer<K>, Deserializer<V>) - Static method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Create a new KafkaConsumer instance

create(Vertx, Properties) - Static method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Create a new KafkaReadStream instance

create(Vertx, Properties, Class<K>, Class<V>) - Static method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Create a new KafkaReadStream instance

create(Vertx, Properties, Deserializer<K>, Deserializer<V>) - Static method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Create a new KafkaReadStream instance

create(Vertx, Map<String, Object>) - Static method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Create a new KafkaReadStream instance

create(Vertx, Map<String, Object>, Class<K>, Class<V>) - Static method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Create a new KafkaReadStream instance

create(Vertx, Map<String, Object>, Deserializer<K>, Deserializer<V>) - Static method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Create a new KafkaReadStream instance

create(Vertx, Consumer<K, V>) - Static method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Create a new KafkaReadStream instance

create(Vertx, Producer<K, V>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Create a new KafkaProducer instance from a native Producer.

create(Vertx, Map<String, String>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Create a new KafkaProducer instance

create(Vertx, Map<String, String>, Serializer<K>, Serializer<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Create a new KafkaProducer instance

create(Vertx, Map<String, String>, Class<K>, Class<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Create a new KafkaProducer instance

create(Vertx, Properties) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Create a new KafkaProducer instance

create(Vertx, Properties, Serializer<K>, Serializer<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Create a new KafkaProducer instance

create(Vertx, Properties, Class<K>, Class<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Create a new KafkaProducer instance

create(String, K, V, Long, Integer) - Static method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

Create a concrete instance of a Vert.x producer record

create(String, K, V, Integer) - Static method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

Create a concrete instance of a Vert.x producer record

create(String, K, V) - Static method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

Create a concrete instance of a Vert.x producer record

create(String, V) - Static method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

Create a concrete instance of a Vert.x producer record

create(Vertx, Properties) - Static method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Create a new KafkaWriteStream instance

create(Vertx, Properties, Class<K>, Class<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Create a new KafkaWriteStream instance

create(Vertx, Properties, Serializer<K>, Serializer<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Create a new KafkaWriteStream instance

create(Vertx, Map<String, Object>) - Static method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Create a new KafkaWriteStream instance

create(Vertx, Map<String, Object>, Class<K>, Class<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Create a new KafkaWriteStream instance

create(Vertx, Map<String, Object>, Serializer<K>, Serializer<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Create a new KafkaWriteStream instance

create(Vertx, Producer<K, V>) - Static method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Create a new KafkaWriteStream instance

createShared(Vertx, String, Properties) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name

createShared(Vertx, String, Map<String, String>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name

createShared(Vertx, String, Map<String, String>, Serializer<K>, Serializer<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name

createShared(Vertx, String, Map<String, String>, Class<K>, Class<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name

createShared(Vertx, String, Properties, Serializer<K>, Serializer<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name

createShared(Vertx, String, Properties, Class<K>, Class<V>) - Static method in interface io.vertx.kafka.client.producer.KafkaProducer

Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name

createTopic(String, int, int, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.admin.AdminUtils

Deprecated.

Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s)

createTopic(String, int, int, Map<String, String>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.admin.AdminUtils

Deprecated.

Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s).

createTopics(List<NewTopic>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.admin.KafkaAdminClient

Creates a batch of new Kafka topics

D

DEFAULT_MAX_SIZE - Static variable in interface io.vertx.kafka.client.producer.KafkaWriteStream

deleteTopic(String, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.admin.AdminUtils

Deprecated.

Delete the Kafka topic given by the topicName.

deleteTopics(List<String>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.admin.KafkaAdminClient

Deletes a batch of Kafka topics

describeConfigs(List<ConfigResource>, Handler<AsyncResult<Map<ConfigResource, Config>>>) - Method in interface io.vertx.kafka.admin.KafkaAdminClient

Get the configuration for the specified resources with the default options

describeConsumerGroups(List<String>, Handler<AsyncResult<Map<String, ConsumerGroupDescription>>>) - Method in interface io.vertx.kafka.admin.KafkaAdminClient

Describe some group ids in the cluster, with the default options

describeTopics(List<String>, Handler<AsyncResult<Map<String, TopicDescription>>>) - Method in interface io.vertx.kafka.admin.KafkaAdminClient

Describe some topics in the cluster, with the default options.

deserialize(String, byte[]) - Method in class io.vertx.kafka.client.serialization.BufferDeserializer

deserialize(String, byte[]) - Method in class io.vertx.kafka.client.serialization.JsonArrayDeserializer

deserialize(String, byte[]) - Method in class io.vertx.kafka.client.serialization.JsonObjectDeserializer

drainHandler(Handler<Void>) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

E

endHandler(Handler<Void>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

endHandler(Handler<Void>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

endOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Get the last offset for the given partitions.

endOffsets(TopicPartition, Handler<AsyncResult<Long>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Get the last offset for the given partition.

endOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Get the last offset for the given partitions.

endOffsets(TopicPartition, Handler<AsyncResult<Long>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Get the last offset for the given partition.

equals(Object) - Method in class io.vertx.kafka.client.common.ConfigResource

equals(Object) - Method in class io.vertx.kafka.client.common.TopicPartition

exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

F

fetch(long) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

fetch(long) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

flush(Handler<Void>) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

Invoking this method makes all buffered records immediately available to write

flush(Handler<Void>) - Method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Invoking this method makes all buffered records immediately available to write

fromJson(Iterable<Map.Entry<String, Object>>, Config) - Static method in class io.vertx.kafka.admin.ConfigConverter

fromJson(Iterable<Map.Entry<String, Object>>, ConfigEntry) - Static method in class io.vertx.kafka.admin.ConfigEntryConverter

fromJson(Iterable<Map.Entry<String, Object>>, ConfigSynonym) - Static method in class io.vertx.kafka.admin.ConfigSynonymConverter

fromJson(Iterable<Map.Entry<String, Object>>, ConsumerGroupDescription) - Static method in class io.vertx.kafka.admin.ConsumerGroupDescriptionConverter

fromJson(Iterable<Map.Entry<String, Object>>, ConsumerGroupListing) - Static method in class io.vertx.kafka.admin.ConsumerGroupListingConverter

fromJson(Iterable<Map.Entry<String, Object>>, MemberAssignment) - Static method in class io.vertx.kafka.admin.MemberAssignmentConverter

fromJson(Iterable<Map.Entry<String, Object>>, MemberDescription) - Static method in class io.vertx.kafka.admin.MemberDescriptionConverter

fromJson(Iterable<Map.Entry<String, Object>>, NewTopic) - Static method in class io.vertx.kafka.admin.NewTopicConverter

fromJson(Iterable<Map.Entry<String, Object>>, TopicDescription) - Static method in class io.vertx.kafka.admin.TopicDescriptionConverter

fromJson(Iterable<Map.Entry<String, Object>>, ConfigResource) - Static method in class io.vertx.kafka.client.common.ConfigResourceConverter

fromJson(Iterable<Map.Entry<String, Object>>, PartitionInfo) - Static method in class io.vertx.kafka.client.common.PartitionInfoConverter

fromJson(Iterable<Map.Entry<String, Object>>, TopicPartitionInfo) - Static method in class io.vertx.kafka.client.common.TopicPartitionInfoConverter

G

getAssignment() - Method in class io.vertx.kafka.admin.MemberDescription

getClientId() - Method in class io.vertx.kafka.admin.MemberDescription

getConfig() - Method in class io.vertx.kafka.admin.NewTopic

getConsumerId() - Method in class io.vertx.kafka.admin.MemberDescription

getCoordinator() - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

getEntries() - Method in class io.vertx.kafka.admin.Config

getGroupId() - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

getGroupId() - Method in class io.vertx.kafka.admin.ConsumerGroupListing

getHost() - Method in class io.vertx.kafka.admin.MemberDescription

getHost() - Method in class io.vertx.kafka.client.common.Node

getId() - Method in class io.vertx.kafka.client.common.Node

getIdString() - Method in class io.vertx.kafka.client.common.Node

getInSyncReplicas() - Method in class io.vertx.kafka.client.common.PartitionInfo

getIsr() - Method in class io.vertx.kafka.client.common.TopicPartitionInfo

getLeader() - Method in class io.vertx.kafka.client.common.PartitionInfo

getLeader() - Method in class io.vertx.kafka.client.common.TopicPartitionInfo

getMembers() - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

getMetadata() - Method in class io.vertx.kafka.client.consumer.OffsetAndMetadata

getName() - Method in class io.vertx.kafka.admin.ConfigEntry

getName() - Method in class io.vertx.kafka.admin.ConfigSynonym

getName() - Method in class io.vertx.kafka.admin.NewTopic

getName() - Method in class io.vertx.kafka.admin.TopicDescription

getName() - Method in class io.vertx.kafka.client.common.ConfigResource

getNumPartitions() - Method in class io.vertx.kafka.admin.NewTopic

getOffset() - Method in class io.vertx.kafka.client.consumer.OffsetAndMetadata

getOffset() - Method in class io.vertx.kafka.client.consumer.OffsetAndTimestamp

getOffset() - Method in class io.vertx.kafka.client.producer.RecordMetadata

getPartition() - Method in class io.vertx.kafka.client.common.PartitionInfo

getPartition() - Method in class io.vertx.kafka.client.common.TopicPartition

getPartition() - Method in class io.vertx.kafka.client.common.TopicPartitionInfo

getPartition() - Method in class io.vertx.kafka.client.producer.RecordMetadata

getPartitionAssignor() - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

getPartitions() - Method in class io.vertx.kafka.admin.TopicDescription

getPort() - Method in class io.vertx.kafka.client.common.Node

getReplicas() - Method in class io.vertx.kafka.client.common.PartitionInfo

getReplicas() - Method in class io.vertx.kafka.client.common.TopicPartitionInfo

getReplicasAssignments() - Method in class io.vertx.kafka.admin.NewTopic

getReplicationFactor() - Method in class io.vertx.kafka.admin.NewTopic

getSource() - Method in class io.vertx.kafka.admin.ConfigEntry

getSource() - Method in class io.vertx.kafka.admin.ConfigSynonym

getState() - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

getSynonyms() - Method in class io.vertx.kafka.admin.ConfigEntry

getTimestamp() - Method in class io.vertx.kafka.client.consumer.OffsetAndTimestamp

getTimestamp() - Method in class io.vertx.kafka.client.producer.RecordMetadata

getTopic() - Method in class io.vertx.kafka.client.common.PartitionInfo

getTopic() - Method in class io.vertx.kafka.client.common.TopicPartition

getTopic() - Method in class io.vertx.kafka.client.producer.RecordMetadata

getTopicPartitions() - Method in class io.vertx.kafka.admin.MemberAssignment

getType() - Method in class io.vertx.kafka.client.common.ConfigResource

getValue() - Method in class io.vertx.kafka.admin.ConfigEntry

getValue() - Method in class io.vertx.kafka.admin.ConfigSynonym

H

handler(Handler<KafkaConsumerRecord<K, V>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

handler(Handler<ConsumerRecord<K, V>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

hashCode() - Method in class io.vertx.kafka.client.common.ConfigResource

hashCode() - Method in class io.vertx.kafka.client.common.TopicPartition

hasRack() - Method in class io.vertx.kafka.client.common.Node

header(String, Buffer) - Static method in interface io.vertx.kafka.client.producer.KafkaHeader

header(String, String) - Static method in interface io.vertx.kafka.client.producer.KafkaHeader

header(String, byte[]) - Static method in interface io.vertx.kafka.client.producer.KafkaHeader

headers() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecord

headers() - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

I

io.vertx.kafka.admin - package io.vertx.kafka.admin

io.vertx.kafka.client.common - package io.vertx.kafka.client.common

io.vertx.kafka.client.consumer - package io.vertx.kafka.client.consumer

io.vertx.kafka.client.producer - package io.vertx.kafka.client.producer

io.vertx.kafka.client.serialization - package io.vertx.kafka.client.serialization

isDefault() - Method in class io.vertx.kafka.admin.ConfigEntry

isDefault() - Method in class io.vertx.kafka.client.common.ConfigResource

isEmpty() - Method in class io.vertx.kafka.client.common.Node

isEmpty() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecords

isInternal() - Method in class io.vertx.kafka.admin.TopicDescription

isReadOnly() - Method in class io.vertx.kafka.admin.ConfigEntry

isSensitive() - Method in class io.vertx.kafka.admin.ConfigEntry

isSimpleConsumerGroup() - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

isSimpleConsumerGroup() - Method in class io.vertx.kafka.admin.ConsumerGroupListing

J

JsonArray() - Static method in class io.vertx.kafka.client.serialization.VertxSerdes

JsonArrayDeserializer - Class in io.vertx.kafka.client.serialization

Kafka deserializer for raw bytes in a buffer

JsonArrayDeserializer() - Constructor for class io.vertx.kafka.client.serialization.JsonArrayDeserializer

JsonArraySerde() - Constructor for class io.vertx.kafka.client.serialization.VertxSerdes.JsonArraySerde

JsonArraySerializer - Class in io.vertx.kafka.client.serialization

Kafka serializer for raw bytes in a buffer

JsonArraySerializer() - Constructor for class io.vertx.kafka.client.serialization.JsonArraySerializer

JsonObject() - Static method in class io.vertx.kafka.client.serialization.VertxSerdes

JsonObjectDeserializer - Class in io.vertx.kafka.client.serialization

Kafka deserializer for raw bytes in a buffer

JsonObjectDeserializer() - Constructor for class io.vertx.kafka.client.serialization.JsonObjectDeserializer

JsonObjectSerde() - Constructor for class io.vertx.kafka.client.serialization.VertxSerdes.JsonObjectSerde

JsonObjectSerializer - Class in io.vertx.kafka.client.serialization

Kafka serializer for raw bytes in a buffer

JsonObjectSerializer() - Constructor for class io.vertx.kafka.client.serialization.JsonObjectSerializer

K

KafkaAdminClient - Interface in io.vertx.kafka.admin

Vert.x Kafka Admin client implementation

KafkaConsumer<K,V> - Interface in io.vertx.kafka.client.consumer

Vert.x Kafka consumer.

KafkaConsumerRecord<K,V> - Interface in io.vertx.kafka.client.consumer

Vert.x Kafka consumer record

KafkaConsumerRecords<K,V> - Interface in io.vertx.kafka.client.consumer

Vert.x Kafka consumer records

KafkaHeader - Interface in io.vertx.kafka.client.producer

Vert.x Kafka producer record header.

KafkaProducer<K,V> - Interface in io.vertx.kafka.client.producer

Vert.x Kafka producer.

KafkaProducerRecord<K,V> - Interface in io.vertx.kafka.client.producer

Vert.x Kafka producer record.

KafkaReadStream<K,V> - Interface in io.vertx.kafka.client.consumer

A ReadStream for consuming Kafka ConsumerRecord.

KafkaWriteStream<K,V> - Interface in io.vertx.kafka.client.producer

A WriteStream for writing to Kafka ProducerRecord.

key() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecord

key() - Method in interface io.vertx.kafka.client.producer.KafkaHeader

key() - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

L

listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>>) - Method in interface io.vertx.kafka.admin.KafkaAdminClient

Get the the consumer groups available in the cluster with the default options

listTopics(Handler<AsyncResult<Set<String>>>) - Method in interface io.vertx.kafka.admin.KafkaAdminClient

List the topics available in the cluster with the default options.

listTopics(Handler<AsyncResult<Map<String, List<PartitionInfo>>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Get metadata about partitions for all topics that the user is authorized to view.

listTopics(Handler<AsyncResult<Map<String, List<PartitionInfo>>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Get metadata about partitions for all topics that the user is authorized to view.

M

MemberAssignment - Class in io.vertx.kafka.admin

A description of the assignments of a specific group member

MemberAssignment() - Constructor for class io.vertx.kafka.admin.MemberAssignment

Constructor

MemberAssignment(Set<TopicPartition>) - Constructor for class io.vertx.kafka.admin.MemberAssignment

Constructor

MemberAssignment(JsonObject) - Constructor for class io.vertx.kafka.admin.MemberAssignment

Constructor (from JSON representation)

MemberAssignmentConverter - Class in io.vertx.kafka.admin

Converter for MemberAssignment.

MemberAssignmentConverter() - Constructor for class io.vertx.kafka.admin.MemberAssignmentConverter

MemberDescription - Class in io.vertx.kafka.admin

A detailed description of a single group instance in the cluster

MemberDescription() - Constructor for class io.vertx.kafka.admin.MemberDescription

Constructor

MemberDescription(String, String, String, MemberAssignment) - Constructor for class io.vertx.kafka.admin.MemberDescription

Constructor

MemberDescription(JsonObject) - Constructor for class io.vertx.kafka.admin.MemberDescription

Constructor (from JSON representation)

MemberDescriptionConverter - Class in io.vertx.kafka.admin

Converter for MemberDescription.

MemberDescriptionConverter() - Constructor for class io.vertx.kafka.admin.MemberDescriptionConverter

N

NewTopic - Class in io.vertx.kafka.admin

A new topic to be created

NewTopic() - Constructor for class io.vertx.kafka.admin.NewTopic

Constructor

NewTopic(String, int, short) - Constructor for class io.vertx.kafka.admin.NewTopic

Constructor

NewTopic(String, Map<Integer, List<Integer>>) - Constructor for class io.vertx.kafka.admin.NewTopic

Constructor

NewTopic(JsonObject) - Constructor for class io.vertx.kafka.admin.NewTopic

Constructor (from JSON representation)

NewTopicConverter - Class in io.vertx.kafka.admin

Converter for NewTopic.

NewTopicConverter() - Constructor for class io.vertx.kafka.admin.NewTopicConverter

Node - Class in io.vertx.kafka.client.common

Information about a Kafka cluster node

Node() - Constructor for class io.vertx.kafka.client.common.Node

Constructor

Node(boolean, String, int, String, boolean, int, String) - Constructor for class io.vertx.kafka.client.common.Node

Constructor

Node(JsonObject) - Constructor for class io.vertx.kafka.client.common.Node

Constructor (from JSON representation)

O

offset() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecord

OffsetAndMetadata - Class in io.vertx.kafka.client.consumer

Provide additional metadata when an offset is committed

OffsetAndMetadata() - Constructor for class io.vertx.kafka.client.consumer.OffsetAndMetadata

Constructor

OffsetAndMetadata(long, String) - Constructor for class io.vertx.kafka.client.consumer.OffsetAndMetadata

Constructor

OffsetAndMetadata(JsonObject) - Constructor for class io.vertx.kafka.client.consumer.OffsetAndMetadata

Constructor (from JSON representation)

OffsetAndMetadata(OffsetAndMetadata) - Constructor for class io.vertx.kafka.client.consumer.OffsetAndMetadata

Constructor (copy)

OffsetAndTimestamp - Class in io.vertx.kafka.client.consumer

Represent information related to a Offset with timestamp information

OffsetAndTimestamp() - Constructor for class io.vertx.kafka.client.consumer.OffsetAndTimestamp

Constructor

OffsetAndTimestamp(long, long) - Constructor for class io.vertx.kafka.client.consumer.OffsetAndTimestamp

Constructor

OffsetAndTimestamp(JsonObject) - Constructor for class io.vertx.kafka.client.consumer.OffsetAndTimestamp

Constructor (from JSON representation)

OffsetAndTimestamp(OffsetAndTimestamp) - Constructor for class io.vertx.kafka.client.consumer.OffsetAndTimestamp

Constructor (copy)

offsetsForTimes(Map<TopicPartition, Long>, Handler<AsyncResult<Map<TopicPartition, OffsetAndTimestamp>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Look up the offsets for the given partitions by timestamp.

offsetsForTimes(TopicPartition, Long, Handler<AsyncResult<OffsetAndTimestamp>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Look up the offset for the given partition by timestamp.

offsetsForTimes(Map<TopicPartition, Long>, Handler<AsyncResult<Map<TopicPartition, OffsetAndTimestamp>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Look up the offsets for the given partitions by timestamp.

offsetsForTimes(TopicPartition, long, Handler<AsyncResult<OffsetAndTimestamp>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

* Look up the offset for the given partition by timestamp.

P

partition() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecord

partition() - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

PartitionInfo - Class in io.vertx.kafka.client.common

Information about a specific Kafka topic partition

PartitionInfo() - Constructor for class io.vertx.kafka.client.common.PartitionInfo

Constructor

PartitionInfo(List<Node>, Node, int, List<Node>, String) - Constructor for class io.vertx.kafka.client.common.PartitionInfo

Constructor

PartitionInfo(JsonObject) - Constructor for class io.vertx.kafka.client.common.PartitionInfo

Constructor (from JSON representation)

PartitionInfoConverter - Class in io.vertx.kafka.client.common

Converter for PartitionInfo.

PartitionInfoConverter() - Constructor for class io.vertx.kafka.client.common.PartitionInfoConverter

partitionsAssignedHandler(Handler<Set<TopicPartition>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Set the handler called when topic partitions are assigned to the consumer

partitionsAssignedHandler(Handler<Set<TopicPartition>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Set the handler called when topic partitions are assigned to the consumer

partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Get metadata about the partitions for a given topic.

partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Get metadata about the partitions for a given topic.

partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

Get the partition metadata for the give topic.

partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>) - Method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Get the partition metadata for the give topic.

partitionsRevokedHandler(Handler<Set<TopicPartition>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Set the handler called when topic partitions are revoked to the consumer

partitionsRevokedHandler(Handler<Set<TopicPartition>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Set the handler called when topic partitions are revoked to the consumer

pause() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

pause(TopicPartition) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Suspend fetching from the requested partition.

pause(Set<TopicPartition>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Suspend fetching from the requested partitions.

pause(TopicPartition, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Suspend fetching from the requested partition.

pause(Set<TopicPartition>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Suspend fetching from the requested partitions.

pause() - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

pause(Set<TopicPartition>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Suspend fetching from the requested partitions.

pause(Set<TopicPartition>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Suspend fetching from the requested partitions.

paused(Handler<AsyncResult<Set<TopicPartition>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Get the set of partitions that were previously paused by a call to pause(Set).

paused(Handler<AsyncResult<Set<TopicPartition>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Get the set of partitions that were previously paused by a call to KafkaReadStream.pause(Set).

poll(long, Handler<AsyncResult<KafkaConsumerRecords<K, V>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Executes a poll for getting messages from Kafka

poll(long, Handler<AsyncResult<ConsumerRecords<K, V>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Executes a poll for getting messages from Kafka

pollTimeout(long) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Sets the poll timeout (in ms) for the underlying native Kafka Consumer.

pollTimeout(long) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Sets the poll timeout (in ms) for the underlying native Kafka Consumer.

position(TopicPartition, Handler<AsyncResult<Long>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

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

position(TopicPartition, Handler<AsyncResult<Long>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

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

R

rack() - Method in class io.vertx.kafka.client.common.Node

record() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecord

record() - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

recordAt(int) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecords

Get the record at the given index

RecordMetadata - Class in io.vertx.kafka.client.producer

Metadata related to a Kafka record

RecordMetadata() - Constructor for class io.vertx.kafka.client.producer.RecordMetadata

Constructor

RecordMetadata(long, long, int, long, String) - Constructor for class io.vertx.kafka.client.producer.RecordMetadata

Constructor

RecordMetadata(JsonObject) - Constructor for class io.vertx.kafka.client.producer.RecordMetadata

Constructor (from JSON representation)

records() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecords

resume() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

resume(TopicPartition) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Resume specified partition which have been paused with pause.

resume(Set<TopicPartition>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Resume specified partitions which have been paused with pause.

resume(TopicPartition, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Resume specified partition which have been paused with pause.

resume(Set<TopicPartition>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Resume specified partitions which have been paused with pause.

resume() - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

resume(Set<TopicPartition>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Resume specified partitions which have been paused with pause.

resume(Set<TopicPartition>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Resume specified partitions which have been paused with pause.

S

seek(TopicPartition, long) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Overrides the fetch offsets that the consumer will use on the next poll.

seek(TopicPartition, long, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Overrides the fetch offsets that the consumer will use on the next poll.

seek(TopicPartition, long) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Overrides the fetch offsets that the consumer will use on the next poll.

seek(TopicPartition, long, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Overrides the fetch offsets that the consumer will use on the next poll.

seekToBeginning(TopicPartition) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Seek to the first offset for each of the given partition.

seekToBeginning(Set<TopicPartition>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Seek to the first offset for each of the given partitions.

seekToBeginning(TopicPartition, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Seek to the first offset for each of the given partition.

seekToBeginning(Set<TopicPartition>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Seek to the first offset for each of the given partitions.

seekToBeginning(Set<TopicPartition>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Seek to the first offset for each of the given partitions.

seekToBeginning(Set<TopicPartition>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Seek to the first offset for each of the given partitions.

seekToEnd(TopicPartition) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Seek to the last offset for each of the given partition.

seekToEnd(Set<TopicPartition>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Seek to the last offset for each of the given partitions.

seekToEnd(TopicPartition, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Seek to the last offset for each of the given partition.

seekToEnd(Set<TopicPartition>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Seek to the last offset for each of the given partitions.

seekToEnd(Set<TopicPartition>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Seek to the last offset for each of the given partitions.

seekToEnd(Set<TopicPartition>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Seek to the last offset for each of the given partitions.

send(KafkaProducerRecord<K, V>) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

Asynchronously write a record to a topic

send(KafkaProducerRecord<K, V>, Handler<AsyncResult<RecordMetadata>>) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

Asynchronously write a record to a topic

send(ProducerRecord<K, V>) - Method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Asynchronously write a record to a topic

send(ProducerRecord<K, V>, Handler<AsyncResult<RecordMetadata>>) - Method in interface io.vertx.kafka.client.producer.KafkaWriteStream

Asynchronously write a record to a topic

serdeFrom(Class<T>) - Static method in class io.vertx.kafka.client.serialization.VertxSerdes

serialize(String, Buffer) - Method in class io.vertx.kafka.client.serialization.BufferSerializer

serialize(String, JsonArray) - Method in class io.vertx.kafka.client.serialization.JsonArraySerializer

serialize(String, JsonObject) - Method in class io.vertx.kafka.client.serialization.JsonObjectSerializer

setAssignment(MemberAssignment) - Method in class io.vertx.kafka.admin.MemberDescription

Set the assignment of the group member

setChecksum(long) - Method in class io.vertx.kafka.client.producer.RecordMetadata

Set the checksum (CRC32) of the record.

setClientId(String) - Method in class io.vertx.kafka.admin.MemberDescription

Set the client id of the group member

setConfig(Map<String, String>) - Method in class io.vertx.kafka.admin.NewTopic

Set the configuration for the new topic or null if no configs ever specified

setConsumerId(String) - Method in class io.vertx.kafka.admin.MemberDescription

Set the consumer id of the group member

setCoordinator(Node) - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

Set the consumer group coordinator, or null if the coordinator is not known

setDefault(boolean) - Method in class io.vertx.kafka.admin.ConfigEntry

Set whether the config value is the default or if it's been explicitly set

setDefault(boolean) - Method in class io.vertx.kafka.client.common.ConfigResource

Set if this is the default resource of a resource type.

setEntries(List<ConfigEntry>) - Method in class io.vertx.kafka.admin.Config

Set the configuration entries for a resource

setGroupId(String) - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

Set the id of the consumer group

setGroupId(String) - Method in class io.vertx.kafka.admin.ConsumerGroupListing

Set the consumer group id

setHasRack(boolean) - Method in class io.vertx.kafka.client.common.Node

Set if this node has a defined rack

setHost(String) - Method in class io.vertx.kafka.admin.MemberDescription

Set the host where the group member is running

setHost(String) - Method in class io.vertx.kafka.client.common.Node

Set the host name for this node

setId(int) - Method in class io.vertx.kafka.client.common.Node

Set the node id of this node

setIdString(String) - Method in class io.vertx.kafka.client.common.Node

Set the string representation of the node id

setInSyncReplicas(List<Node>) - Method in class io.vertx.kafka.client.common.PartitionInfo

Set the subset of the replicas that are in sync

setInternal(boolean) - Method in class io.vertx.kafka.admin.TopicDescription

Set whether the topic is internal to Kafka.

setIsEmpty(boolean) - Method in class io.vertx.kafka.client.common.Node

Set if this node is empty

setIsr(List<Node>) - Method in class io.vertx.kafka.client.common.TopicPartitionInfo

Set the subset of the replicas that are in sync

setLeader(Node) - Method in class io.vertx.kafka.client.common.PartitionInfo

Set the node id of the node currently acting as a leader

setLeader(Node) - Method in class io.vertx.kafka.client.common.TopicPartitionInfo

Set the node id of the node currently acting as a leader

setMembers(List<MemberDescription>) - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

Set a list of the members of the consumer group

setMetadata(String) - Method in class io.vertx.kafka.client.consumer.OffsetAndMetadata

Set additional metadata for the offset committed

setName(String) - Method in class io.vertx.kafka.admin.ConfigEntry

Set the config name

setName(String) - Method in class io.vertx.kafka.admin.ConfigSynonym

Set the name of this configuration

setName(String) - Method in class io.vertx.kafka.admin.NewTopic

Set the name of the topic to be created

setName(String) - Method in class io.vertx.kafka.admin.TopicDescription

Set the name of the topic.

setName(String) - Method in class io.vertx.kafka.client.common.ConfigResource

Set the resource name

setNumPartitions(int) - Method in class io.vertx.kafka.admin.NewTopic

Set the number of partitions for the new topic or -1 if a replica assignment has been specified

setOffset(long) - Method in class io.vertx.kafka.client.consumer.OffsetAndMetadata

Set the offset to commit

setOffset(long) - Method in class io.vertx.kafka.client.consumer.OffsetAndTimestamp

Set the offset

setOffset(long) - Method in class io.vertx.kafka.client.producer.RecordMetadata

Set the offset of the record in the topic/partition.

setPartition(int) - Method in class io.vertx.kafka.client.common.PartitionInfo

Set the partition id

setPartition(int) - Method in class io.vertx.kafka.client.common.TopicPartition

Set the partition number

setPartition(int) - Method in class io.vertx.kafka.client.common.TopicPartitionInfo

Set the partition id

setPartition(int) - Method in class io.vertx.kafka.client.producer.RecordMetadata

Set the partition the record was sent to

setPartitionAssignor(String) - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

Set the consumer group partition assignor

setPartitions(List<TopicPartitionInfo>) - Method in class io.vertx.kafka.admin.TopicDescription

Set A list of partitions where the index represents the partition id and the element contains leadership and replica information for that partition.

setPort(int) - Method in class io.vertx.kafka.client.common.Node

Set the port for this node

setRack(String) - Method in class io.vertx.kafka.client.common.Node

Set the rack for this node

setReadOnly(boolean) - Method in class io.vertx.kafka.admin.ConfigEntry

Set whether the config is read-only and cannot be updated

setReplicas(List<Node>) - Method in class io.vertx.kafka.client.common.PartitionInfo

Set the complete set of replicas for this partition

setReplicas(List<Node>) - Method in class io.vertx.kafka.client.common.TopicPartitionInfo

Set the complete set of replicas for this partition

setReplicasAssignments(Map<Integer, List<Integer>>) - Method in class io.vertx.kafka.admin.NewTopic

Set a map from partition id to replica ids

setReplicationFactor(short) - Method in class io.vertx.kafka.admin.NewTopic

Set the replication factor for the new topic or -1 if a replica assignment has been specified

setSensitive(boolean) - Method in class io.vertx.kafka.admin.ConfigEntry

Set whether the config value is sensitive.

setSimpleConsumerGroup(boolean) - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

Set if consumer group is simple or not

setSimpleConsumerGroup(boolean) - Method in class io.vertx.kafka.admin.ConsumerGroupListing

Set if consumer group is simple or not

setSource(ConfigEntry.ConfigSource) - Method in class io.vertx.kafka.admin.ConfigEntry

Set the source of this configuration entry

setSource(ConfigEntry.ConfigSource) - Method in class io.vertx.kafka.admin.ConfigSynonym

Set the source of this configuration

setState(ConsumerGroupState) - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

Set the consumer group state, or UNKNOWN if the state is too new for us to parse

setSynonyms(List<ConfigSynonym>) - Method in class io.vertx.kafka.admin.ConfigEntry

Set all config values that may be used as the value of this config along with their source, in the order of precedence

setTimestamp(long) - Method in class io.vertx.kafka.client.consumer.OffsetAndTimestamp

Set the timestamp

setTimestamp(long) - Method in class io.vertx.kafka.client.producer.RecordMetadata

Set the timestamp of the record in the topic/partition

setTopic(String) - Method in class io.vertx.kafka.client.common.PartitionInfo

Set the topic name

setTopic(String) - Method in class io.vertx.kafka.client.common.TopicPartition

Set the topic name

setTopic(String) - Method in class io.vertx.kafka.client.producer.RecordMetadata

Set the topic the record was appended to

setTopicPartitions(Set<TopicPartition>) - Method in class io.vertx.kafka.admin.MemberAssignment

Set the list of topic partitions

setType(ConfigResource.Type) - Method in class io.vertx.kafka.client.common.ConfigResource

Set the resource type

setValue(String) - Method in class io.vertx.kafka.admin.ConfigEntry

Set the value or null.

setValue(String) - Method in class io.vertx.kafka.admin.ConfigSynonym

Set the value of this configuration, which may be null if the configuration is sensitive

setWriteQueueMaxSize(int) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

size() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecords

subscribe(String) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Subscribe to the given topic to get dynamically assigned partitions.

subscribe(Set<String>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Subscribe to the given list of topics to get dynamically assigned partitions.

subscribe(String, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Subscribe to the given topic to get dynamically assigned partitions.

subscribe(Set<String>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Subscribe to the given list of topics to get dynamically assigned partitions.

subscribe(Pattern) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Subscribe to all topics matching specified pattern to get dynamically assigned partitions.

subscribe(Pattern, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Subscribe to all topics matching specified pattern to get dynamically assigned partitions.

subscribe(Set<String>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Subscribe to the given list of topics to get dynamically assigned partitions.

subscribe(Set<String>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Subscribe to the given list of topics to get dynamically assigned partitions.

subscribe(Pattern, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Subscribe to all topics matching specified pattern to get dynamically assigned partitions.

subscribe(Pattern) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Subscribe to all topics matching specified pattern to get dynamically assigned partitions.

subscription(Handler<AsyncResult<Set<String>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Get the current subscription.

subscription(Handler<AsyncResult<Set<String>>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Get the current subscription.

T

timestamp() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecord

timestamp() - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

timestampType() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecord

toJson() - Method in class io.vertx.kafka.admin.Config

Convert object to JSON representation

toJson(Config, JsonObject) - Static method in class io.vertx.kafka.admin.ConfigConverter

toJson(Config, Map<String, Object>) - Static method in class io.vertx.kafka.admin.ConfigConverter

toJson() - Method in class io.vertx.kafka.admin.ConfigEntry

Convert object to JSON representation

toJson(ConfigEntry, JsonObject) - Static method in class io.vertx.kafka.admin.ConfigEntryConverter

toJson(ConfigEntry, Map<String, Object>) - Static method in class io.vertx.kafka.admin.ConfigEntryConverter

toJson() - Method in class io.vertx.kafka.admin.ConfigSynonym

Convert object to JSON representation

toJson(ConfigSynonym, JsonObject) - Static method in class io.vertx.kafka.admin.ConfigSynonymConverter

toJson(ConfigSynonym, Map<String, Object>) - Static method in class io.vertx.kafka.admin.ConfigSynonymConverter

toJson() - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

Convert object to JSON representation

toJson(ConsumerGroupDescription, JsonObject) - Static method in class io.vertx.kafka.admin.ConsumerGroupDescriptionConverter

toJson(ConsumerGroupDescription, Map<String, Object>) - Static method in class io.vertx.kafka.admin.ConsumerGroupDescriptionConverter

toJson() - Method in class io.vertx.kafka.admin.ConsumerGroupListing

Convert object to JSON representation

toJson(ConsumerGroupListing, JsonObject) - Static method in class io.vertx.kafka.admin.ConsumerGroupListingConverter

toJson(ConsumerGroupListing, Map<String, Object>) - Static method in class io.vertx.kafka.admin.ConsumerGroupListingConverter

toJson() - Method in class io.vertx.kafka.admin.MemberAssignment

Convert object to JSON representation

toJson(MemberAssignment, JsonObject) - Static method in class io.vertx.kafka.admin.MemberAssignmentConverter

toJson(MemberAssignment, Map<String, Object>) - Static method in class io.vertx.kafka.admin.MemberAssignmentConverter

toJson() - Method in class io.vertx.kafka.admin.MemberDescription

Convert object to JSON representation

toJson(MemberDescription, JsonObject) - Static method in class io.vertx.kafka.admin.MemberDescriptionConverter

toJson(MemberDescription, Map<String, Object>) - Static method in class io.vertx.kafka.admin.MemberDescriptionConverter

toJson() - Method in class io.vertx.kafka.admin.NewTopic

Convert object to JSON representation

toJson(NewTopic, JsonObject) - Static method in class io.vertx.kafka.admin.NewTopicConverter

toJson(NewTopic, Map<String, Object>) - Static method in class io.vertx.kafka.admin.NewTopicConverter

toJson() - Method in class io.vertx.kafka.admin.TopicDescription

Convert object to JSON representation

toJson(TopicDescription, JsonObject) - Static method in class io.vertx.kafka.admin.TopicDescriptionConverter

toJson(TopicDescription, Map<String, Object>) - Static method in class io.vertx.kafka.admin.TopicDescriptionConverter

toJson() - Method in class io.vertx.kafka.client.common.ConfigResource

Convert object to JSON representation

toJson(ConfigResource, JsonObject) - Static method in class io.vertx.kafka.client.common.ConfigResourceConverter

toJson(ConfigResource, Map<String, Object>) - Static method in class io.vertx.kafka.client.common.ConfigResourceConverter

toJson() - Method in class io.vertx.kafka.client.common.Node

Convert object to JSON representation

toJson() - Method in class io.vertx.kafka.client.common.PartitionInfo

Convert object to JSON representation

toJson(PartitionInfo, JsonObject) - Static method in class io.vertx.kafka.client.common.PartitionInfoConverter

toJson(PartitionInfo, Map<String, Object>) - Static method in class io.vertx.kafka.client.common.PartitionInfoConverter

toJson() - Method in class io.vertx.kafka.client.common.TopicPartition

Convert object to JSON representation

toJson() - Method in class io.vertx.kafka.client.common.TopicPartitionInfo

Convert object to JSON representation

toJson(TopicPartitionInfo, JsonObject) - Static method in class io.vertx.kafka.client.common.TopicPartitionInfoConverter

toJson(TopicPartitionInfo, Map<String, Object>) - Static method in class io.vertx.kafka.client.common.TopicPartitionInfoConverter

toJson() - Method in class io.vertx.kafka.client.consumer.OffsetAndMetadata

Convert object to JSON representation

toJson() - Method in class io.vertx.kafka.client.consumer.OffsetAndTimestamp

Convert object to JSON representation

toJson() - Method in class io.vertx.kafka.client.producer.RecordMetadata

Convert object to JSON representation

topic() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecord

topic() - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

TopicDescription - Class in io.vertx.kafka.admin

A detailed description of a single topic in the cluster

TopicDescription() - Constructor for class io.vertx.kafka.admin.TopicDescription

Constructor

TopicDescription(boolean, String, List<TopicPartitionInfo>) - Constructor for class io.vertx.kafka.admin.TopicDescription

Constructor

TopicDescription(JsonObject) - Constructor for class io.vertx.kafka.admin.TopicDescription

Constructor (from JSON representation)

TopicDescriptionConverter - Class in io.vertx.kafka.admin

Converter for TopicDescription.

TopicDescriptionConverter() - Constructor for class io.vertx.kafka.admin.TopicDescriptionConverter

topicExists(String, Handler<AsyncResult<Boolean>>) - Method in interface io.vertx.kafka.admin.AdminUtils

Deprecated.

Checks if the Kafka topic given by topicName does exist.

TopicPartition - Class in io.vertx.kafka.client.common

Represent information related to a partition for a topic

TopicPartition() - Constructor for class io.vertx.kafka.client.common.TopicPartition

Constructor

TopicPartition(String, int) - Constructor for class io.vertx.kafka.client.common.TopicPartition

Constructor

TopicPartition(JsonObject) - Constructor for class io.vertx.kafka.client.common.TopicPartition

Constructor (from JSON representation)

TopicPartition(TopicPartition) - Constructor for class io.vertx.kafka.client.common.TopicPartition

Constructor (copy)

TopicPartitionInfo - Class in io.vertx.kafka.client.common

A class containing leadership, replicas and ISR information for a topic partition.

TopicPartitionInfo() - Constructor for class io.vertx.kafka.client.common.TopicPartitionInfo

Constructor

TopicPartitionInfo(List<Node>, Node, int, List<Node>) - Constructor for class io.vertx.kafka.client.common.TopicPartitionInfo

Constructor

TopicPartitionInfo(JsonObject) - Constructor for class io.vertx.kafka.client.common.TopicPartitionInfo

Constructor (from JSON representation)

TopicPartitionInfoConverter - Class in io.vertx.kafka.client.common

Converter for TopicPartitionInfo.

TopicPartitionInfoConverter() - Constructor for class io.vertx.kafka.client.common.TopicPartitionInfoConverter

toString() - Method in class io.vertx.kafka.admin.Config

toString() - Method in class io.vertx.kafka.admin.ConfigEntry

toString() - Method in class io.vertx.kafka.admin.ConfigSynonym

toString() - Method in class io.vertx.kafka.admin.ConsumerGroupDescription

toString() - Method in class io.vertx.kafka.admin.ConsumerGroupListing

toString() - Method in class io.vertx.kafka.admin.MemberAssignment

toString() - Method in class io.vertx.kafka.admin.MemberDescription

toString() - Method in class io.vertx.kafka.admin.NewTopic

toString() - Method in class io.vertx.kafka.admin.TopicDescription

toString() - Method in class io.vertx.kafka.client.common.ConfigResource

toString() - Method in class io.vertx.kafka.client.common.Node

toString() - Method in class io.vertx.kafka.client.common.PartitionInfo

toString() - Method in class io.vertx.kafka.client.common.TopicPartition

toString() - Method in class io.vertx.kafka.client.common.TopicPartitionInfo

toString() - Method in class io.vertx.kafka.client.consumer.OffsetAndMetadata

toString() - Method in class io.vertx.kafka.client.consumer.OffsetAndTimestamp

U

unsubscribe() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Unsubscribe from topics currently subscribed with subscribe.

unsubscribe(Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

Unsubscribe from topics currently subscribed with subscribe.

unsubscribe() - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Unsubscribe from topics currently subscribed with subscribe.

unsubscribe(Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

Unsubscribe from topics currently subscribed with subscribe.

unwrap() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumer

unwrap() - Method in interface io.vertx.kafka.client.consumer.KafkaReadStream

unwrap() - Method in interface io.vertx.kafka.client.producer.KafkaProducer

unwrap() - Method in interface io.vertx.kafka.client.producer.KafkaWriteStream

V

value() - Method in interface io.vertx.kafka.client.consumer.KafkaConsumerRecord

value() - Method in interface io.vertx.kafka.client.producer.KafkaHeader

value() - Method in interface io.vertx.kafka.client.producer.KafkaProducerRecord

VertxSerdes - Class in io.vertx.kafka.client.serialization

VertxSerdes() - Constructor for class io.vertx.kafka.client.serialization.VertxSerdes

VertxSerdes.BufferSerde - Class in io.vertx.kafka.client.serialization

VertxSerdes.JsonArraySerde - Class in io.vertx.kafka.client.serialization

VertxSerdes.JsonObjectSerde - Class in io.vertx.kafka.client.serialization

W

write(KafkaProducerRecord<K, V>) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

write(KafkaProducerRecord<K, V>, Handler<AsyncResult<Void>>) - Method in interface io.vertx.kafka.client.producer.KafkaProducer

writeQueueFull() - Method in interface io.vertx.kafka.client.producer.KafkaProducer

A B C D E F G H I J K L M N O P R S T U V W