Dependencies
Declarations
-
examples
-
AdminUtilsExamples
-
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
-
AdminUtils
-
create(Vertx, String): AdminUtils
-
create(Vertx, String, boolean): AdminUtils
-
create(Vertx, String, int, boolean, boolean): AdminUtils
-
createTopic(String, int, int, Handler<AsyncResult<Void>>): void
-
createTopic(String, int, int, Map<String, String>, Handler<AsyncResult<Void>>): void
-
deleteTopic(String, Handler<AsyncResult<Void>>): void
-
topicExists(String, Handler<AsyncResult<Boolean>>): void
-
changeTopicConfig(String, Map<String, String>, Handler<AsyncResult<Void>>): void
-
close(Handler<AsyncResult<Void>>): void
-
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
-
describeTopics(List<String>, Handler<AsyncResult<Map<String, TopicDescription>>>): void
-
createTopics(List<NewTopic>, Handler<AsyncResult<Void>>): void
-
deleteTopics(List<String>, Handler<AsyncResult<Void>>): void
-
describeConfigs(List<ConfigResource>, Handler<AsyncResult<Map<ConfigResource, Config>>>): void
-
alterConfigs(Map<ConfigResource, Config>, Handler<AsyncResult<Void>>): void
-
listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>>): void
-
describeConsumerGroups(List<String>, Handler<AsyncResult<Map<String, ConsumerGroupDescription>>>): void
-
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
-
TopicDescription
-
TopicDescriptionConverter
-
impl
-
AdminUtilsImpl
-
vertx: Vertx
-
zookeeper: String
-
isSecure: boolean
-
connectionTimeoutMs: int
-
zkUtils: ZkUtils
-
autoClose: boolean
-
AdminUtilsImpl(Vertx, String, int, boolean, boolean): void
-
AdminUtilsImpl(Vertx, String): void
-
AdminUtilsImpl(Vertx, String, boolean): void
-
createTopic(String, int, int, Handler<AsyncResult<Void>>): void
-
createTopic(String, int, int, Map<String, String>, Handler<AsyncResult<Void>>): void
-
deleteTopic(String, Handler<AsyncResult<Void>>): void
-
topicExists(String, Handler<AsyncResult<Boolean>>): void
-
changeTopicConfig(String, Map<String, String>, Handler<AsyncResult<Void>>): void
-
close(Handler<AsyncResult<Void>>): void
-
initZkClientAndGetZkUtils(): ZkUtils
-
KafkaAdminClientImpl
-
vertx: Vertx
-
adminClient: AdminClient
-
KafkaAdminClientImpl(Vertx, AdminClient): void
-
describeTopics(List<String>, Handler<AsyncResult<Map<String, TopicDescription>>>): void
-
listTopics(Handler<AsyncResult<Set<String>>>): void
-
createTopics(List<NewTopic>, Handler<AsyncResult<Void>>): void
-
deleteTopics(List<String>, Handler<AsyncResult<Void>>): void
-
describeConfigs(List<ConfigResource>, Handler<AsyncResult<Map<ConfigResource, Config>>>): void
-
alterConfigs(Map<ConfigResource, Config>, Handler<AsyncResult<Void>>): void
-
listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>>): void
-
describeConsumerGroups(List<String>, Handler<AsyncResult<Map<String, ConsumerGroupDescription>>>): void
-
client
-
common
-
consumer
-
KafkaConsumer
-
subscribe(Set<String>): KafkaConsumer<Object, Object>
-
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, 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>
-
endHandler(Handler<Void>): KafkaConsumer<Object, Object>
-
subscribe(String): KafkaConsumer<Object, Object>
-
subscribe(String, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
subscribe(Set<String>, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
subscribe(Pattern): KafkaConsumer<Object, Object>
-
subscribe(Pattern, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
assign(TopicPartition): KafkaConsumer<Object, Object>
-
assign(Set<TopicPartition>): KafkaConsumer<Object, Object>
-
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>
-
listTopics(Handler<AsyncResult<Map<String, List<PartitionInfo>>>>): KafkaConsumer<Object, Object>
-
unsubscribe(): KafkaConsumer<Object, Object>
-
unsubscribe(Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
subscription(Handler<AsyncResult<Set<String>>>): KafkaConsumer<Object, Object>
-
pause(TopicPartition): KafkaConsumer<Object, Object>
-
pause(Set<TopicPartition>): KafkaConsumer<Object, Object>
-
pause(TopicPartition, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
pause(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
paused(Handler<AsyncResult<Set<TopicPartition>>>): void
-
resume(TopicPartition): KafkaConsumer<Object, Object>
-
resume(Set<TopicPartition>): KafkaConsumer<Object, Object>
-
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): KafkaConsumer<Object, Object>
-
seek(TopicPartition, long, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
seekToBeginning(TopicPartition): KafkaConsumer<Object, Object>
-
seekToBeginning(Set<TopicPartition>): KafkaConsumer<Object, Object>
-
seekToBeginning(TopicPartition, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
seekToBeginning(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
seekToEnd(TopicPartition): KafkaConsumer<Object, Object>
-
seekToEnd(Set<TopicPartition>): KafkaConsumer<Object, Object>
-
seekToEnd(TopicPartition, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
seekToEnd(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaConsumer<Object, Object>
-
commit(): void
-
commit(Handler<AsyncResult<Void>>): void
-
commit(Map<TopicPartition, OffsetAndMetadata>): void
-
commit(Map<TopicPartition, OffsetAndMetadata>, Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>): void
-
committed(TopicPartition, Handler<AsyncResult<OffsetAndMetadata>>): void
-
partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>): KafkaConsumer<Object, Object>
-
batchHandler(Handler<KafkaConsumerRecords<Object, Object>>): KafkaConsumer<Object, Object>
-
close(): void
-
close(Handler<AsyncResult<Void>>): void
-
position(TopicPartition, Handler<AsyncResult<Long>>): void
-
offsetsForTimes(Map<TopicPartition, Long>, Handler<AsyncResult<Map<TopicPartition, OffsetAndTimestamp>>>): void
-
offsetsForTimes(TopicPartition, Long, Handler<AsyncResult<OffsetAndTimestamp>>): void
-
beginningOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>): void
-
beginningOffsets(TopicPartition, Handler<AsyncResult<Long>>): void
-
endOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>): void
-
endOffsets(TopicPartition, Handler<AsyncResult<Long>>): void
-
asStream(): KafkaReadStream<Object, Object>
-
unwrap(): Consumer<Object, Object>
-
pollTimeout(long): KafkaConsumer<Object, Object>
-
poll(long, Handler<AsyncResult<KafkaConsumerRecords<Object, Object>>>): void
-
KafkaConsumerRecord
-
KafkaConsumerRecords
-
KafkaReadStream
-
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, Consumer<Object, Object>): KafkaReadStream<Object, Object>
-
committed(TopicPartition, Handler<AsyncResult<OffsetAndMetadata>>): void
-
pause(Set<TopicPartition>): KafkaReadStream<Object, Object>
-
pause(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
paused(Handler<AsyncResult<Set<TopicPartition>>>): void
-
resume(Set<TopicPartition>): KafkaReadStream<Object, Object>
-
resume(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
seekToEnd(Set<TopicPartition>): KafkaReadStream<Object, Object>
-
seekToEnd(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
seekToBeginning(Set<TopicPartition>): KafkaReadStream<Object, Object>
-
seekToBeginning(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
seek(TopicPartition, long): KafkaReadStream<Object, Object>
-
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>): KafkaReadStream<Object, Object>
-
subscribe(Set<String>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
subscribe(Pattern, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
subscribe(Pattern): KafkaReadStream<Object, Object>
-
unsubscribe(): KafkaReadStream<Object, Object>
-
unsubscribe(Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
subscription(Handler<AsyncResult<Set<String>>>): KafkaReadStream<Object, Object>
-
assign(Set<TopicPartition>): KafkaReadStream<Object, Object>
-
assign(Set<TopicPartition>, Handler<AsyncResult<Void>>): KafkaReadStream<Object, Object>
-
assignment(Handler<AsyncResult<Set<TopicPartition>>>): KafkaReadStream<Object, Object>
-
listTopics(Handler<AsyncResult<Map<String, List<PartitionInfo>>>>): KafkaReadStream<Object, Object>
-
commit(): void
-
commit(Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>): void
-
commit(Map<TopicPartition, OffsetAndMetadata>): void
-
commit(Map<TopicPartition, OffsetAndMetadata>, Handler<AsyncResult<Map<TopicPartition, OffsetAndMetadata>>>): void
-
partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>): KafkaReadStream<Object, Object>
-
close(): void
-
close(Handler<AsyncResult<Void>>): void
-
position(TopicPartition, Handler<AsyncResult<Long>>): void
-
offsetsForTimes(Map<TopicPartition, Long>, Handler<AsyncResult<Map<TopicPartition, OffsetAndTimestamp>>>): void
-
offsetsForTimes(TopicPartition, long, Handler<AsyncResult<OffsetAndTimestamp>>): void
-
beginningOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>): void
-
beginningOffsets(TopicPartition, Handler<AsyncResult<Long>>): void
-
endOffsets(Set<TopicPartition>, Handler<AsyncResult<Map<TopicPartition, Long>>>): void
-
endOffsets(TopicPartition, Handler<AsyncResult<Long>>): void
-
unwrap(): Consumer<Object, Object>
-
batchHandler(Handler<ConsumerRecords<Object, Object>>): KafkaReadStream<Object, Object>
-
pollTimeout(long): KafkaReadStream<Object, Object>
-
poll(long, Handler<AsyncResult<ConsumerRecords<Object, Object>>>): void
-
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, 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>
-
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>
-
exceptionHandler(Handler<Throwable>): KafkaProducer<Object, Object>
-
write(KafkaProducerRecord<Object, Object>): KafkaProducer<Object, Object>
-
setWriteQueueMaxSize(int): KafkaProducer<Object, Object>
-
writeQueueFull(): boolean
-
drainHandler(Handler<Void>): KafkaProducer<Object, Object>
-
write(KafkaProducerRecord<Object, Object>, Handler<AsyncResult<Void>>): KafkaProducer<Object, Object>
-
send(KafkaProducerRecord<Object, Object>): KafkaProducer<Object, Object>
-
send(KafkaProducerRecord<Object, Object>, Handler<AsyncResult<RecordMetadata>>): KafkaProducer<Object, Object>
-
partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>): KafkaProducer<Object, Object>
-
flush(Handler<Void>): KafkaProducer<Object, Object>
-
close(): void
-
close(Handler<AsyncResult<Void>>): 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, Producer<Object, Object>): KafkaWriteStream<Object, Object>
-
send(ProducerRecord<Object, Object>): KafkaWriteStream<Object, Object>
-
send(ProducerRecord<Object, Object>, Handler<AsyncResult<RecordMetadata>>): KafkaWriteStream<Object, Object>
-
partitionsFor(String, Handler<AsyncResult<List<PartitionInfo>>>): KafkaWriteStream<Object, Object>
-
flush(Handler<Void>): KafkaWriteStream<Object, Object>
-
close(): void
-
close(Handler<AsyncResult<Void>>): void
-
close(long, Handler<AsyncResult<Void>>): void
-
unwrap(): Producer<Object, Object>
-
RecordMetadata
-
impl
-
serialization
Java files
Class files