Dependencies
Declarations
-
examples
-
KafkaAdminClientExamples
-
VertxKafkaClientExamples
-
exampleCreateConsumerJava(Vertx): void
-
exampleCreateConsumer(Vertx): void
-
createProducer(Vertx): void
-
createProducerJava(Vertx): void
-
exampleSubscribe(KafkaConsumer<String, String>): void
-
exampleSubscribeWithResult(KafkaConsumer<String, String>): void
-
exampleConsumerPartitionsNotifs(KafkaConsumer<String, String>): void
-
exampleUnsubscribe(KafkaConsumer<String, String>): void
-
exampleUnsubscribeWithCallback(KafkaConsumer<String, String>): void
-
exampleConsumerAssignPartition(KafkaConsumer<String, String>): void
-
exampleConsumerPartitionsFor(KafkaConsumer<String, String>): void
-
exampleConsumerListTopics(KafkaConsumer<String, String>): void
-
exampleConsumerWithPoll(Vertx, KafkaConsumer<String, String>): void
-
exampleProducerPartitionsFor(KafkaProducer<String, String>): void
-
exampleConsumerManualOffsetCommit(KafkaConsumer<String, String>): void
-
exampleSeek(KafkaConsumer<String, String>): void
-
exampleSeekToBeginning(KafkaConsumer<String, String>): void
-
exampleSeekToEnd(KafkaConsumer<String, String>): void
-
exampleConsumerBeginningOffsets(KafkaConsumer<String, String>): void
-
exampleConsumerEndOffsets(KafkaConsumer<String, String>): void
-
exampleConsumerOffsetsForTimes(KafkaConsumer<String, String>): void
-
exampleConsumerFlowControl(Vertx, KafkaConsumer<String, String>): void
-
exampleConsumerClose(KafkaConsumer<String, String>): void
-
exampleProducerWrite(KafkaProducer<String, String>): void
-
exampleProducerWriteWithAck(KafkaProducer<String, String>): void
-
exampleProducerWriteWithSpecificPartition(KafkaProducer<String, String>): void
-
exampleProducerWriteWithSpecificKey(KafkaProducer<String, String>): void
-
exampleSharedProducer(Vertx, Map<String, String>): void
-
exampleProducerClose(KafkaProducer<String, String>): void
-
exampleErrorHandling(KafkaConsumer<String, String>): void
-
exampleUsingVertxDeserializers(): void
-
exampleUsingVertxSerializers(): void
-
exampleUsingVertxDeserializers2(Vertx): void
-
exampleUsingVertxSerializers2(Vertx): void
-
io
-
vertx
-
kafka
-
admin
-
ClusterDescription
-
ClusterDescriptionConverter
-
Config
-
ConfigConverter
-
ConfigEntry
-
ConfigEntryConverter
-
ConfigSynonym
-
ConfigSynonymConverter
-
ConsumerGroupDescription
-
ConsumerGroupDescriptionConverter
-
ConsumerGroupListing
-
ConsumerGroupListingConverter
-
KafkaAdminClient
-
create(Vertx, AdminClient): KafkaAdminClient
-
create(Vertx, Map<String, String>): KafkaAdminClient
-
create(Vertx, Properties): KafkaAdminClient
-
listTopics(Handler<AsyncResult<Set<String>>>): void
-
listTopics(): Future<Set<String>>
-
describeTopics(List<String>, Handler<AsyncResult<Map<String, TopicDescription>>>): void
-
describeTopics(List<String>): Future<Map<String, TopicDescription>>
-
createTopics(List<NewTopic>, Handler<AsyncResult<Void>>): void
-
createTopics(List<NewTopic>): Future<Void>
-
deleteTopics(List<String>, Handler<AsyncResult<Void>>): void
-
deleteTopics(List<String>): Future<Void>
-
describeConfigs(List<ConfigResource>, Handler<AsyncResult<Map<ConfigResource, Config>>>): void
-
describeConfigs(List<ConfigResource>): Future<Map<ConfigResource, Config>>
-
alterConfigs(Map<ConfigResource, Config>, Handler<AsyncResult<Void>>): void
-
alterConfigs(Map<ConfigResource, Config>): Future<Void>
-
listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>>): void
-
listConsumerGroups(): Future<List<ConsumerGroupListing>>
-
describeConsumerGroups(List<String>, Handler<AsyncResult<Map<String, ConsumerGroupDescription>>>): void
-
describeConsumerGroups(List<String>): Future<Map<String, ConsumerGroupDescription>>
-
describeCluster(Handler<AsyncResult<ClusterDescription>>): void
-
describeCluster(): Future<ClusterDescription>
-
deleteConsumerGroups(List<String>, Handler<AsyncResult<Void>>): void
-
deleteConsumerGroups(List<String>): Future<Void>
-
listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions, Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>): void
-
listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions): Future<Map<TopicPartition, OffsetAndMetadata>>
-
listConsumerGroupOffsets(String, Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>): void
-
listConsumerGroupOffsets(String): Future<Map<TopicPartition, OffsetAndMetadata>>
-
deleteConsumerGroupOffsets(String, Set<TopicPartition>, Handler<AsyncResult<Void>>): void
-
deleteConsumerGroupOffsets(String, Set<TopicPartition>): Future<Void>
-
listOffsets(Map<TopicPartition, OffsetSpec>, Handler<AsyncResult<Map<TopicPartition, ListOffsetsResultInfo>>>): void
-
listOffsets(Map<TopicPartition, OffsetSpec>): Future<Map<TopicPartition, ListOffsetsResultInfo>>
-
close(Handler<AsyncResult<Void>>): void
-
close(): Future<Void>
-
close(long, Handler<AsyncResult<Void>>): void
-
close(long): Future<Void>
-
ListConsumerGroupOffsetsOptions
-
ListConsumerGroupOffsetsOptionsConverter
-
ListOffsetsResultInfo
-
ListOffsetsResultInfoConverter
-
MemberAssignment
-
MemberAssignmentConverter
-
MemberDescription
-
MemberDescriptionConverter
-
NewTopic
-
name: String
-
numPartitions: int
-
replicationFactor: short
-
replicasAssignments: Map<Integer, List<Integer>>
-
config: Map<String, String>
-
NewTopic(): void
-
NewTopic(String, int, short): void
-
NewTopic(String, Map<Integer, List<Integer>>): void
-
NewTopic(JsonObject): void
-
getName(): String
-
setName(String): NewTopic
-
getNumPartitions(): int
-
setNumPartitions(int): NewTopic
-
getReplicationFactor(): short
-
setReplicationFactor(short): NewTopic
-
getReplicasAssignments(): Map<Integer, List<Integer>>
-
setReplicasAssignments(Map<Integer, List<Integer>>): NewTopic
-
getConfig(): Map<String, String>
-
setConfig(Map<String, String>): NewTopic
-
toJson(): JsonObject
-
toString(): String
-
NewTopicConverter
-
OffsetSpec
-
OffsetSpecConverter
-
TopicDescription
-
TopicDescriptionConverter
-
impl
-
KafkaAdminClientImpl
-
vertx: Vertx
-
adminClient: AdminClient
-
KafkaAdminClientImpl(Vertx, AdminClient): void
-
describeTopics(List<String>, Handler<AsyncResult<Map<String, TopicDescription>>>): void
-
describeTopics(List<String>): Future<Map<String, TopicDescription>>
-
listTopics(Handler<AsyncResult<Set<String>>>): void
-
listTopics(): Future<Set<String>>
-
createTopics(List<NewTopic>, Handler<AsyncResult<Void>>): void
-
createTopics(List<NewTopic>): Future<Void>
-
deleteTopics(List<String>, Handler<AsyncResult<Void>>): void
-
deleteTopics(List<String>): Future<Void>
-
describeConfigs(List<ConfigResource>, Handler<AsyncResult<Map<ConfigResource, Config>>>): void
-
describeConfigs(List<ConfigResource>): Future<Map<ConfigResource, Config>>
-
alterConfigs(Map<ConfigResource, Config>, Handler<AsyncResult<Void>>): void
-
alterConfigs(Map<ConfigResource, Config>): Future<Void>
-
listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>>): void
-
listConsumerGroups(): Future<List<ConsumerGroupListing>>
-
describeConsumerGroups(List<String>, Handler<AsyncResult<Map<String, ConsumerGroupDescription>>>): void
-
describeConsumerGroups(List<String>): Future<Map<String, ConsumerGroupDescription>>
-
listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions, Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>): void
-
listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions): Future<Map<TopicPartition, OffsetAndMetadata>>
-
deleteConsumerGroups(List<String>, Handler<AsyncResult<Void>>): void
-
deleteConsumerGroups(List<String>): Future<Void>
-
deleteConsumerGroupOffsets(String, Set<TopicPartition>, Handler<AsyncResult<Void>>): void
-
deleteConsumerGroupOffsets(String, Set<TopicPartition>): Future<Void>
-
describeCluster(Handler<AsyncResult<ClusterDescription>>): void
-
describeCluster(): Future<ClusterDescription>
-
listOffsets(Map<TopicPartition, OffsetSpec>, Handler<AsyncResult<Map<TopicPartition, ListOffsetsResultInfo>>>): void
-
listOffsets(Map<TopicPartition, OffsetSpec>): Future<Map<TopicPartition, ListOffsetsResultInfo>>
-
close(): Future<Void>
-
close(long): Future<Void>
-
close(Handler<AsyncResult<Void>>): void
-
close(long, Handler<AsyncResult<Void>>): void
-
client
-
common
-
consumer
-
KafkaConsumer
-
create(Vertx, Consumer<Object, Object>): KafkaConsumer<Object, Object>
-
create(Vertx, Map<String, String>): KafkaConsumer<Object, Object>
-
create(Vertx, Map<String, String>, Class<Object>, Class<Object>): KafkaConsumer<Object, Object>
-
create(Vertx, Map<String, String>, Deserializer<Object>, Deserializer<Object>): KafkaConsumer<Object, Object>
-
create(Vertx, KafkaClientOptions): KafkaConsumer<Object, Object>
-
create(Vertx, KafkaClientOptions, Class<Object>, Class<Object>): KafkaConsumer<Object, Object>
-
create(Vertx, KafkaClientOptions, Deserializer<Object>, Deserializer<Object>): KafkaConsumer<Object, Object>
-
create(Vertx, Properties): KafkaConsumer<Object, Object>
-
create(Vertx, Properties, Class<Object>, Class<Object>): KafkaConsumer<Object, Object>
-
create(Vertx, Properties, Deserializer<Object>, Deserializer<Object>): KafkaConsumer<Object, Object>
-
exceptionHandler(Handler<Throwable>): KafkaConsumer<Object, Object>
-
handler(Handler<KafkaConsumerRecord<Object, Object>>): KafkaConsumer<Object, Object>
-
pause(): KafkaConsumer<Object, Object>
-
resume(): KafkaConsumer<Object, Object>
-
fetch(long): KafkaConsumer<Object, Object>
-
endHandler(Handler<Void>): KafkaConsumer<Object, Object>
-
demand(): long
-
subscribe(String): Future<Void>
-
subscribe(Set<String>): Future<Void>
-
subscribe(String, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
subscribe(Set<String>, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
subscribe(Pattern): Future<Void>
-
subscribe(Pattern, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
assign(TopicPartition): Future<Void>
-
assign(Set<TopicPartition>): Future<Void>
-
seek(TopicPartition, long): Future<Void>
-
assign(TopicPartition, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
assign(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
assignment(Handler<AsyncResult<Set<TopicPartition>>>): KafkaConsumer<Object, Object>
-
assignment(): Future<Set<TopicPartition>>
-
listTopics(Handler<AsyncResult<Map<String, List<PartitionInfo>>>>): KafkaConsumer<Object, Object>
-
listTopics(): Future<Map<String, List<PartitionInfo>>>
-
unsubscribe(): Future<Void>
-
unsubscribe(Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
subscription(Handler<AsyncResult<Set<String>>>): KafkaConsumer<Object, Object>
-
subscription(): Future<Set<String>>
-
pause(TopicPartition): Future<Void>
-
pause(Set<TopicPartition>): Future<Void>
-
pause(TopicPartition, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
pause(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
paused(Handler<AsyncResult<Set<TopicPartition>>>): void
-
paused(): Future<Set<TopicPartition>>
-
resume(TopicPartition): Future<Void>
-
resume(Set<TopicPartition>): Future<Void>
-
resume(TopicPartition, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
resume(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
partitionsRevokedHandler(Handler<Set<TopicPartition>>): KafkaConsumer<Object, Object>
-
partitionsAssignedHandler(Handler<Set<TopicPartition>>): KafkaConsumer<Object, Object>
-
seek(TopicPartition, long, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
seekToBeginning(TopicPartition): Future<Void>
-
seekToBeginning(Set<TopicPartition>): Future<Void>
-
seekToBeginning(TopicPartition, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
seekToBeginning(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
seekToEnd(TopicPartition): Future<Void>
-
seekToEnd(Set<TopicPartition>): Future<Void>
-
seekToEnd(TopicPartition, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
seekToEnd(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
commit(): Future<Void>
-
commit(Handler<AsyncResult<Void>>): void
-
commit(Map<TopicPartition, OffsetAndMetadata>): Future<Map<TopicPartition, OffsetAndMetadata>>
-
commit(Map<TopicPartition, OffsetAndMetadata>, Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>): void
-
committed(TopicPartition, Handler<AsyncResult<OffsetAndMetadata>>): void
-
committed(TopicPartition): Future<OffsetAndMetadata>
-
partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>): KafkaConsumer<Object, Object>
-
partitionsFor(String): Future<List<PartitionInfo>>
-
batchHandler(Handler<KafkaConsumerRecords<Object, Object>>): KafkaConsumer<Object, Object>
-
close(): Future<Void>
-
close(Handler<AsyncResult<Void>>): void
-
position(TopicPartition, Handler<AsyncResult<Long>>): void
-
position(TopicPartition): Future<Long>
-
offsetsForTimes(Map<TopicPartition, Long>, Handler<AsyncResult<Map<TopicPartition, OffsetAndTimestamp>>>): void
-
offsetsForTimes(Map<TopicPartition, Long>): Future<Map<TopicPartition, OffsetAndTimestamp>>
-
offsetsForTimes(TopicPartition, Long, Handler<AsyncResult<OffsetAndTimestamp>>): void
-
offsetsForTimes(TopicPartition, Long): Future<OffsetAndTimestamp>
-
beginningOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>): void
-
beginningOffsets(Set<TopicPartition>): Future<Map<TopicPartition, Long>>
-
beginningOffsets(TopicPartition, Handler<AsyncResult<Long>>): void
-
beginningOffsets(TopicPartition): Future<Long>
-
endOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>): void
-
endOffsets(Set<TopicPartition>): Future<Map<TopicPartition, Long>>
-
endOffsets(TopicPartition, Handler<AsyncResult<Long>>): void
-
endOffsets(TopicPartition): Future<Long>
-
asStream(): KafkaReadStream<Object, Object>
-
unwrap(): Consumer<Object, Object>
-
pollTimeout(Duration): KafkaConsumer<Object, Object>
-
poll(Duration, Handler<AsyncResult<KafkaConsumerRecords<Object, Object>>>): void
-
poll(Duration): Future<KafkaConsumerRecords<Object, Object>>
-
KafkaConsumerRecord
-
KafkaConsumerRecords
-
KafkaReadStream
-
exceptionHandler(Handler<Throwable>): KafkaReadStream<Object, Object>
-
handler(Handler<ConsumerRecord<Object, Object>>): KafkaReadStream<Object, Object>
-
pause(): KafkaReadStream<Object, Object>
-
resume(): KafkaReadStream<Object, Object>
-
fetch(long): KafkaReadStream<Object, Object>
-
endHandler(Handler<Void>): KafkaReadStream<Object, Object>
-
demand(): long
-
create(Vertx, Properties): KafkaReadStream<Object, Object>
-
create(Vertx, Properties, Class<Object>, Class<Object>): KafkaReadStream<Object, Object>
-
create(Vertx, Properties, Deserializer<Object>, Deserializer<Object>): KafkaReadStream<Object, Object>
-
create(Vertx, Map<String, Object>): KafkaReadStream<Object, Object>
-
create(Vertx, Map<String, Object>, Class<Object>, Class<Object>): KafkaReadStream<Object, Object>
-
create(Vertx, Map<String, Object>, Deserializer<Object>, Deserializer<Object>): KafkaReadStream<Object, Object>
-
create(Vertx, KafkaClientOptions): KafkaReadStream<Object, Object>
-
create(Vertx, KafkaClientOptions, Class<Object>, Class<Object>): KafkaReadStream<Object, Object>
-
create(Vertx, KafkaClientOptions, Deserializer<Object>, Deserializer<Object>): KafkaReadStream<Object, Object>
-
create(Vertx, Consumer<Object, Object>): KafkaReadStream<Object, Object>
-
committed(TopicPartition, Handler<AsyncResult<OffsetAndMetadata>>): void
-
committed(TopicPartition): Future<OffsetAndMetadata>
-
pause(Set<TopicPartition>): Future<Void>
-
pause(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
paused(Handler<AsyncResult<Set<TopicPartition>>>): void
-
paused(): Future<Set<TopicPartition>>
-
resume(Set<TopicPartition>): Future<Void>
-
resume(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
seekToEnd(Set<TopicPartition>): Future<Void>
-
seekToEnd(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
seekToBeginning(Set<TopicPartition>): Future<Void>
-
seekToBeginning(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
seek(TopicPartition, long): Future<Void>
-
seek(TopicPartition, long, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
partitionsRevokedHandler(Handler<Set<TopicPartition>>): KafkaReadStream<Object, Object>
-
partitionsAssignedHandler(Handler<Set<TopicPartition>>): KafkaReadStream<Object, Object>
-
subscribe(Set<String>): Future<Void>
-
subscribe(Set<String>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
subscribe(Pattern, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
subscribe(Pattern): Future<Void>
-
unsubscribe(): Future<Void>
-
unsubscribe(Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
subscription(Handler<AsyncResult<Set<String>>>): KafkaReadStream<Object, Object>
-
subscription(): Future<Set<String>>
-
assign(Set<TopicPartition>): Future<Void>
-
assign(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
assignment(Handler<AsyncResult<Set<TopicPartition>>>): KafkaReadStream<Object, Object>
-
assignment(): Future<Set<TopicPartition>>
-
listTopics(Handler<AsyncResult<Map<String, List<PartitionInfo>>>>): KafkaReadStream<Object, Object>
-
listTopics(): Future<Map<String, List<PartitionInfo>>>
-
commit(): Future<Map<TopicPartition, OffsetAndMetadata>>
-
commit(Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>): void
-
commit(Map<TopicPartition, OffsetAndMetadata>): Future<Map<TopicPartition, OffsetAndMetadata>>
-
commit(Map<TopicPartition, OffsetAndMetadata>, Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>): void
-
partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>): KafkaReadStream<Object, Object>
-
partitionsFor(String): Future<List<PartitionInfo>>
-
close(): Future<Void>
-
close(Handler<AsyncResult<Void>>): void
-
position(TopicPartition, Handler<AsyncResult<Long>>): void
-
position(TopicPartition): Future<Long>
-
offsetsForTimes(Map<TopicPartition, Long>, Handler<AsyncResult<Map<TopicPartition, OffsetAndTimestamp>>>): void
-
offsetsForTimes(Map<TopicPartition, Long>): Future<Map<TopicPartition, OffsetAndTimestamp>>
-
offsetsForTimes(TopicPartition, long, Handler<AsyncResult<OffsetAndTimestamp>>): void
-
offsetsForTimes(TopicPartition, long): Future<OffsetAndTimestamp>
-
beginningOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>): void
-
beginningOffsets(Set<TopicPartition>): Future<Map<TopicPartition, Long>>
-
beginningOffsets(TopicPartition, Handler<AsyncResult<Long>>): void
-
beginningOffsets(TopicPartition): Future<Long>
-
endOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>): void
-
endOffsets(Set<TopicPartition>): Future<Map<TopicPartition, Long>>
-
endOffsets(TopicPartition, Handler<AsyncResult<Long>>): void
-
endOffsets(TopicPartition): Future<Long>
-
unwrap(): Consumer<Object, Object>
-
batchHandler(Handler<ConsumerRecords<Object, Object>>): KafkaReadStream<Object, Object>
-
pollTimeout(Duration): KafkaReadStream<Object, Object>
-
poll(Duration, Handler<AsyncResult<ConsumerRecords<Object, Object>>>): void
-
poll(Duration): Future<ConsumerRecords<Object, Object>>
-
OffsetAndMetadata
-
OffsetAndTimestamp
-
impl
-
producer
-
KafkaHeader
-
KafkaProducer
-
createShared(Vertx, String, Properties): KafkaProducer<Object, Object>
-
createShared(Vertx, String, Map<String, String>): KafkaProducer<Object, Object>
-
createShared(Vertx, String, KafkaClientOptions): KafkaProducer<Object, Object>
-
createShared(Vertx, String, Map<String, String>, Serializer<Object>, Serializer<Object>): KafkaProducer<Object, Object>
-
createShared(Vertx, String, Map<String, String>, Class<Object>, Class<Object>): KafkaProducer<Object, Object>
-
createShared(Vertx, String, Properties, Serializer<Object>, Serializer<Object>): KafkaProducer<Object, Object>
-
createShared(Vertx, String, Properties, Class<Object>, Class<Object>): KafkaProducer<Object, Object>
-
createShared(Vertx, String, KafkaClientOptions, Serializer<Object>, Serializer<Object>): KafkaProducer<Object, Object>
-
createShared(Vertx, String, KafkaClientOptions, Class<Object>, Class<Object>): KafkaProducer<Object, Object>
-
create(Vertx, Producer<Object, Object>): KafkaProducer<Object, Object>
-
create(Vertx, Map<String, String>): KafkaProducer<Object, Object>
-
create(Vertx, Map<String, String>, Serializer<Object>, Serializer<Object>): KafkaProducer<Object, Object>
-
create(Vertx, Map<String, String>, Class<Object>, Class<Object>): KafkaProducer<Object, Object>
-
create(Vertx, Properties): KafkaProducer<Object, Object>
-
create(Vertx, Properties, Serializer<Object>, Serializer<Object>): KafkaProducer<Object, Object>
-
create(Vertx, Properties, Class<Object>, Class<Object>): KafkaProducer<Object, Object>
-
initTransactions(Handler<AsyncResult<Void>>): KafkaProducer<Object, Object>
-
initTransactions(): Future<Void>
-
beginTransaction(Handler<AsyncResult<Void>>): KafkaProducer<Object, Object>
-
beginTransaction(): Future<Void>
-
commitTransaction(Handler<AsyncResult<Void>>): KafkaProducer<Object, Object>
-
commitTransaction(): Future<Void>
-
abortTransaction(Handler<AsyncResult<Void>>): KafkaProducer<Object, Object>
-
abortTransaction(): Future<Void>
-
exceptionHandler(Handler<Throwable>): KafkaProducer<Object, Object>
-
setWriteQueueMaxSize(int): KafkaProducer<Object, Object>
-
drainHandler(Handler<Void>): KafkaProducer<Object, Object>
-
send(KafkaProducerRecord<Object, Object>): Future<RecordMetadata>
-
send(KafkaProducerRecord<Object, Object>, Handler<AsyncResult<RecordMetadata>>): KafkaProducer<Object, Object>
-
partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>): KafkaProducer<Object, Object>
-
partitionsFor(String): Future<List<PartitionInfo>>
-
flush(Handler<AsyncResult<Void>>): KafkaProducer<Object, Object>
-
flush(): Future<Void>
-
close(): Future<Void>
-
close(Handler<AsyncResult<Void>>): void
-
close(long): Future<Void>
-
close(long, Handler<AsyncResult<Void>>): void
-
asStream(): KafkaWriteStream<Object, Object>
-
unwrap(): Producer<Object, Object>
-
KafkaProducerRecord
-
create(String, Object, Object, Long, Integer): KafkaProducerRecord<Object, Object>
-
create(String, Object, Object, Integer): KafkaProducerRecord<Object, Object>
-
create(String, Object, Object): KafkaProducerRecord<Object, Object>
-
create(String, Object): KafkaProducerRecord<Object, Object>
-
topic(): String
-
key(): Object
-
value(): Object
-
timestamp(): Long
-
partition(): Integer
-
addHeader(String, String): KafkaProducerRecord<Object, Object>
-
addHeader(String, Buffer): KafkaProducerRecord<Object, Object>
-
addHeader(KafkaHeader): KafkaProducerRecord<Object, Object>
-
addHeaders(List<KafkaHeader>): KafkaProducerRecord<Object, Object>
-
headers(): List<KafkaHeader>
-
record(): ProducerRecord<Object, Object>
-
KafkaWriteStream
-
DEFAULT_MAX_SIZE: int
-
create(Vertx, Properties): KafkaWriteStream<Object, Object>
-
create(Vertx, Properties, Class<Object>, Class<Object>): KafkaWriteStream<Object, Object>
-
create(Vertx, Properties, Serializer<Object>, Serializer<Object>): KafkaWriteStream<Object, Object>
-
create(Vertx, Map<String, Object>): KafkaWriteStream<Object, Object>
-
create(Vertx, Map<String, Object>, Class<Object>, Class<Object>): KafkaWriteStream<Object, Object>
-
create(Vertx, Map<String, Object>, Serializer<Object>, Serializer<Object>): KafkaWriteStream<Object, Object>
-
create(Vertx, KafkaClientOptions): KafkaWriteStream<Object, Object>
-
create(Vertx, KafkaClientOptions, Class<Object>, Class<Object>): KafkaWriteStream<Object, Object>
-
create(Vertx, KafkaClientOptions, Serializer<Object>, Serializer<Object>): KafkaWriteStream<Object, Object>
-
create(Vertx, Producer<Object, Object>): KafkaWriteStream<Object, Object>
-
exceptionHandler(Handler<Throwable>): KafkaWriteStream<Object, Object>
-
setWriteQueueMaxSize(int): KafkaWriteStream<Object, Object>
-
drainHandler(Handler<Void>): KafkaWriteStream<Object, Object>
-
initTransactions(Handler<AsyncResult<Void>>): KafkaWriteStream<Object, Object>
-
initTransactions(): Future<Void>
-
beginTransaction(Handler<AsyncResult<Void>>): KafkaWriteStream<Object, Object>
-
beginTransaction(): Future<Void>
-
commitTransaction(Handler<AsyncResult<Void>>): KafkaWriteStream<Object, Object>
-
commitTransaction(): Future<Void>
-
abortTransaction(Handler<AsyncResult<Void>>): KafkaWriteStream<Object, Object>
-
abortTransaction(): Future<Void>
-
send(ProducerRecord<Object, Object>): Future<RecordMetadata>
-
send(ProducerRecord<Object, Object>, Handler<AsyncResult<RecordMetadata>>): KafkaWriteStream<Object, Object>
-
partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>): KafkaWriteStream<Object, Object>
-
partitionsFor(String): Future<List<PartitionInfo>>
-
flush(Handler<AsyncResult<Void>>): KafkaWriteStream<Object, Object>
-
flush(): Future<Void>
-
close(): Future<Void>
-
close(Handler<AsyncResult<Void>>): void
-
close(long, Handler<AsyncResult<Void>>): void
-
close(long): Future<Void>
-
unwrap(): Producer<Object, Object>
-
RecordMetadata
-
impl
-
serialization
Java files
Class files