Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- backport-util-concurrent/backport-util-concurrent/3.1
- classworlds/classworlds/1.1-alpha-2 (available as org.codehaus.plexus/plexus-classworlds/2.6.0)
- com.101tec/zkclient/0.10
- com.fasterxml.jackson.core/jackson-annotations/2.9.0
- com.fasterxml.jackson.core/jackson-core/2.9.9
- com.fasterxml.jackson.core/jackson-databind/2.9.9.1
- com.github.jponge/lzma-java/1.3
- com.github.luben/zstd-jni/1.3.5-4
- com.google.code.findbugs/annotations/3.0.1u2
- com.google.code.findbugs/jsr305/3.0.1
- com.google.code.gson/gson/2.8.5
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.h2database/h2/1.4.196
- com.jcraft/jzlib/1.1.3
- commons-cli/commons-cli/1.1
- commons-codec/commons-codec/1.6
- commons-collections/commons-collections/3.2.2
- commons-io/commons-io/2.0.1
- commons-lang/commons-lang/2.4
- commons-logging/commons-logging/1.2
- com.ning/compress-lzf/1.0.3
- com.sun.mail/mailapi/1.6.1
- com.sun/tools/1.8
- com.typesafe.scala-logging/scala-logging_2.12/3.9.0
- com.vdurmont/semver4j/2.2.0
- com.yammer.metrics/metrics-core/2.2.0
- io.netty/netty-buffer/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-core/3.8.0
- io.vertx/vertx-docgen/0.9.2
- java/11
- javax.activation/activation/1.1
- javax.json/javax.json-api/1.0
- javax.mail/mail/1.4.1
- jdiff/jdiff/1.0.9
- jdk.tools/jdk.tools/1.8
- joda-time/joda-time/1.6
- log4j/log4j/1.2.16
- logkit/logkit/1.0.1
- nekohtml/nekohtml/1.9.6.2
- nekohtml/xercesMinimal/1.9.6.2
- net.jcip/jcip-annotations/1.0
- net.jpountz.lz4/lz4/1.3.0
- net.sf.jopt-simple/jopt-simple/5.0.4
- org.apache.ant/ant/1.8.0
- org.apache.ant/ant-launcher/1.8.0
- org.apache.commons/commons-compress/1.0
- org.apache.commons/commons-lang3/3.7
- org.apache.commons/commons-text/1.3
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.httpcomponents/httpclient/4.2.3
- org.apache.httpcomponents/httpcore/4.2.3
- org.apache.kafka/kafka_2.12/2.1.0
- org.apache.kafka/kafka-clients/2.1.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.apache.lucene/lucene-analyzers-common/5.5.5
- org.apache.lucene/lucene-core/5.5.5
- org.apache.lucene/lucene-queries/5.5.5
- org.apache.lucene/lucene-queryparser/5.5.5
- org.apache.lucene/lucene-sandbox/5.5.5
- org.apache.maven/maven-ant-tasks/2.1.3
- org.apache.maven/maven-artifact/2.2.1
- org.apache.maven/maven-artifact-manager/2.2.1
- org.apache.maven/maven-error-diagnostics/2.2.1
- org.apache.maven/maven-model/2.2.1
- org.apache.maven/maven-plugin-api/2.1.0
- org.apache.maven/maven-plugin-registry/2.2.1
- org.apache.maven/maven-profile/2.2.1
- org.apache.maven/maven-project/2.2.1
- org.apache.maven/maven-repository-metadata/2.2.1
- org.apache.maven/maven-settings/2.2.1
- org.apache.maven.wagon/wagon-file/1.0-beta-6
- org.apache.maven.wagon/wagon-http/2.4
- org.apache.maven.wagon/wagon-http-lightweight/1.0-beta-6
- org.apache.maven.wagon/wagon-http-shared/1.0-beta-6
- org.apache.maven.wagon/wagon-http-shared4/2.4
- org.apache.maven.wagon/wagon-provider-api/2.4
- org.apache.rat/apache-rat-core/0.6
- org.apache.rat/apache-rat-tasks/0.6
- org.apache.velocity/velocity/1.7
- org.apache.yetus/audience-annotations/0.5.0
- org.apache.zookeeper/zookeeper/3.4.13
- org.bouncycastle/bcpg-jdk12/130
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk12/130
- org.bouncycastle/bcprov-jdk15on/1.54
- org.codehaus.plexus/plexus-container-default/1.0-alpha-9-stable-1
- org.codehaus.plexus/plexus-interpolation/1.11
- org.codehaus.plexus/plexus-utils/1.4.1
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.glassfish/javax.json/1.0.4
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.jsoup/jsoup/1.7.1
- org.lz4/lz4-java/1.5.0
- org.mvel/mvel2/2.3.1.Final
- org.openclover/clover/4.2.1
- org.owasp/dependency-check-ant/3.2.1
- org.owasp/dependency-check-core/3.2.1
- org.owasp/dependency-check-utils/3.2.1
- org.scala-lang/scala-reflect/2.12.7
- org.slf4j/slf4j-api/1.7.21
- org.slf4j/slf4j-log4j12/1.7.21
- org.vafer/jdeb/0.8
- org.xerial.snappy/snappy-java/1.1.7.2
- oro/oro/2.0.8
- xerces/xerces/1.4.4 (available as xerces/xercesImpl/2.12.0)
- xerces/xercesImpl/2.9.0
- xml-apis/xml-apis/1.3.04
- xml-resolver/xml-resolver/1.2
Declarations
-
examples
-
AdminUtilsExamples
-
KafkaAdminClientExamples
-
exampleCreateAdminClient(Vertx): void
-
exampleListTopics(KafkaAdminClient): void
-
exampleDescribeTopics(KafkaAdminClient): void
-
exampleDeleteTopics(KafkaAdminClient): void
-
exampleCreateTopics(KafkaAdminClient): void
-
exampleDescribeConfigs(KafkaAdminClient): void
-
exampleAlterConfigs(KafkaAdminClient): void
-
exampleListConsumerGroups(KafkaAdminClient): void
-
exampleDescribeConsumerGroups(KafkaAdminClient): void
-
-
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
-
isReadOnly(): boolean
-
name: String
-
isDefault: boolean
-
isReadOnly: boolean
-
isSensitive: boolean
-
source: ConfigSource
-
synonyms: List<ConfigSynonym>
-
value: String
-
ConfigEntry(): void
-
ConfigEntry(String, String): void
-
ConfigEntry(JsonObject): void
-
getName(): String
-
setName(String): ConfigEntry
-
isDefault(): boolean
-
setReadOnly(boolean): ConfigEntry
-
setDefault(boolean): ConfigEntry
-
isSensitive(): boolean
-
setSensitive(boolean): ConfigEntry
-
getSource(): ConfigSource
-
setSource(ConfigSource): ConfigEntry
-
getSynonyms(): List<ConfigSynonym>
-
setSynonyms(List<ConfigSynonym>): ConfigEntry
-
getValue(): String
-
setValue(String): ConfigEntry
-
toJson(): JsonObject
-
toString(): String
-
-
ConfigEntryConverter
-
ConfigSynonym
-
name: String
-
value: String
-
source: ConfigSource
-
ConfigSynonym(): void
-
ConfigSynonym(String, String, ConfigSource): void
-
ConfigSynonym(JsonObject): void
-
getName(): String
-
setName(String): ConfigSynonym
-
getValue(): String
-
setValue(String): ConfigSynonym
-
getSource(): ConfigSource
-
setSource(ConfigSource): ConfigSynonym
-
toJson(): JsonObject
-
toString(): String
-
-
ConfigSynonymConverter
-
ConsumerGroupDescription
-
groupId: String
-
isSimpleConsumerGroup: boolean
-
coordinator: Node
-
members: List<MemberDescription>
-
partitionAssignor: String
-
state: ConsumerGroupState
-
ConsumerGroupDescription(): void
-
ConsumerGroupDescription(String, boolean, List<MemberDescription>, String, ConsumerGroupState, Node): void
-
ConsumerGroupDescription(JsonObject): void
-
getGroupId(): String
-
setGroupId(String): ConsumerGroupDescription
-
isSimpleConsumerGroup(): boolean
-
setSimpleConsumerGroup(boolean): ConsumerGroupDescription
-
getCoordinator(): Node
-
setCoordinator(Node): ConsumerGroupDescription
-
getMembers(): List<MemberDescription>
-
setMembers(List<MemberDescription>): ConsumerGroupDescription
-
getPartitionAssignor(): String
-
setPartitionAssignor(String): ConsumerGroupDescription
-
getState(): ConsumerGroupState
-
setState(ConsumerGroupState): ConsumerGroupDescription
-
toJson(): JsonObject
-
toString(): String
-
-
ConsumerGroupDescriptionConverter
-
ConsumerGroupListing
-
groupId: String
-
isSimpleConsumerGroup: boolean
-
ConsumerGroupListing(): void
-
ConsumerGroupListing(String, boolean): void
-
ConsumerGroupListing(JsonObject): void
-
getGroupId(): String
-
setGroupId(String): ConsumerGroupListing
-
isSimpleConsumerGroup(): boolean
-
setSimpleConsumerGroup(boolean): ConsumerGroupListing
-
toJson(): JsonObject
-
toString(): String
-
-
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
-
consumerId: String
-
clientId: String
-
assignment: MemberAssignment
-
host: String
-
MemberDescription(): void
-
MemberDescription(String, String, String, MemberAssignment): void
-
MemberDescription(JsonObject): void
-
getConsumerId(): String
-
setConsumerId(String): MemberDescription
-
getClientId(): String
-
setClientId(String): MemberDescription
-
getAssignment(): MemberAssignment
-
setAssignment(MemberAssignment): MemberDescription
-
getHost(): String
-
setHost(String): MemberDescription
-
toJson(): JsonObject
-
toString(): String
-
-
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
-
TopicDescription(JsonObject): void
-
partitions: List<TopicPartitionInfo>
-
TopicDescription(): void
-
name: String
-
isInternal: boolean
-
TopicDescription(boolean, String, List<TopicPartitionInfo>): void
-
isInternal(): boolean
-
setInternal(boolean): TopicDescription
-
getName(): String
-
setName(String): TopicDescription
-
getPartitions(): List<TopicPartitionInfo>
-
setPartitions(List<TopicPartitionInfo>): TopicDescription
-
toJson(): JsonObject
-
toString(): String
-
-
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
-
ConfigResource
-
equals(Object): boolean
-
hashCode(): int
-
toString(): String
-
name: String
-
isDefault: boolean
-
type: Type
-
ConfigResource(): void
-
ConfigResource(Type, String): void
-
ConfigResource(JsonObject): void
-
getName(): String
-
setName(String): ConfigResource
-
isDefault(): boolean
-
setDefault(boolean): ConfigResource
-
getType(): Type
-
setType(Type): ConfigResource
-
toJson(): JsonObject
-
-
ConfigResourceConverter
-
Node
-
hasRack: boolean
-
host: String
-
id: int
-
idString: String
-
isEmpty: boolean
-
port: int
-
rack: String
-
Node(): void
-
Node(boolean, String, int, String, boolean, int, String): void
-
Node(JsonObject): void
-
hasRack(): boolean
-
setHasRack(boolean): Node
-
getHost(): String
-
setHost(String): Node
-
getId(): int
-
setId(int): Node
-
getIdString(): String
-
setIdString(String): Node
-
isEmpty(): boolean
-
setIsEmpty(boolean): Node
-
getPort(): int
-
setPort(int): Node
-
rack(): String
-
setRack(String): Node
-
toJson(): JsonObject
-
toString(): String
-
-
PartitionInfo
-
inSyncReplicas: List<Node>
-
leader: Node
-
partition: int
-
replicas: List<Node>
-
topic: String
-
PartitionInfo(): void
-
PartitionInfo(List<Node>, Node, int, List<Node>, String): void
-
PartitionInfo(JsonObject): void
-
getInSyncReplicas(): List<Node>
-
setInSyncReplicas(List<Node>): PartitionInfo
-
getLeader(): Node
-
setLeader(Node): PartitionInfo
-
getPartition(): int
-
setPartition(int): PartitionInfo
-
getReplicas(): List<Node>
-
setReplicas(List<Node>): PartitionInfo
-
getTopic(): String
-
setTopic(String): PartitionInfo
-
toJson(): JsonObject
-
toString(): String
-
-
PartitionInfoConverter
-
TopicPartition
-
hashCode(): int
-
topic: String
-
partition: int
-
TopicPartition(): void
-
TopicPartition(String, int): void
-
TopicPartition(JsonObject): void
-
TopicPartition(TopicPartition): void
-
getTopic(): String
-
setTopic(String): TopicPartition
-
getPartition(): int
-
setPartition(int): TopicPartition
-
toJson(): JsonObject
-
toString(): String
-
equals(Object): boolean
-
-
TopicPartitionInfo
-
isr: List<Node>
-
leader: Node
-
partition: int
-
replicas: List<Node>
-
TopicPartitionInfo(): void
-
TopicPartitionInfo(List<Node>, Node, int, List<Node>): void
-
TopicPartitionInfo(JsonObject): void
-
getIsr(): List<Node>
-
setIsr(List<Node>): TopicPartitionInfo
-
getLeader(): Node
-
setLeader(Node): TopicPartitionInfo
-
getPartition(): int
-
setPartition(int): TopicPartitionInfo
-
getReplicas(): List<Node>
-
setReplicas(List<Node>): TopicPartitionInfo
-
toJson(): JsonObject
-
toString(): String
-
-
TopicPartitionInfoConverter
- impl
-
-
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
-
offset: long
-
metadata: String
-
OffsetAndMetadata(): void
-
OffsetAndMetadata(long, String): void
-
OffsetAndMetadata(JsonObject): void
-
OffsetAndMetadata(OffsetAndMetadata): void
-
getOffset(): long
-
setOffset(long): OffsetAndMetadata
-
getMetadata(): String
-
setMetadata(String): OffsetAndMetadata
-
toJson(): JsonObject
-
toString(): String
-
-
OffsetAndTimestamp
-
setOffset(long): OffsetAndTimestamp
-
OffsetAndTimestamp(JsonObject): void
-
offset: long
-
timestamp: long
-
OffsetAndTimestamp(): void
-
OffsetAndTimestamp(long, long): void
-
OffsetAndTimestamp(OffsetAndTimestamp): void
-
getOffset(): long
-
getTimestamp(): long
-
setTimestamp(long): OffsetAndTimestamp
-
toJson(): JsonObject
-
toString(): String
-
- 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
-
checksum: long
-
offset: long
-
partition: int
-
timestamp: long
-
topic: String
-
RecordMetadata(): void
-
RecordMetadata(long, long, int, long, String): void
-
RecordMetadata(JsonObject): void
-
checksum(): long
-
setChecksum(long): RecordMetadata
-
getOffset(): long
-
setOffset(long): RecordMetadata
-
getPartition(): int
-
setPartition(int): RecordMetadata
-
getTimestamp(): long
-
setTimestamp(long): RecordMetadata
-
getTopic(): String
-
setTopic(String): RecordMetadata
-
toJson(): JsonObject
-
- impl
-
- serialization
-
common
-
admin
-
kafka
-
vertx