A C I K P R T
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- apply(ProducerRecord<K, V>) - Method in class io.apicurio.registry.utils.kafka.AsyncProducer
- AsyncProducer<K,V> - Class in io.apicurio.registry.utils.kafka
-
An async wrapper for kafka producer that is resilient in the event of failures - it recreates the underlying kafka producer when unrecoverable error occurs.
- AsyncProducer(Properties, Serializer<K>, Serializer<V>) - Constructor for class io.apicurio.registry.utils.kafka.AsyncProducer
C
- close() - Method in class io.apicurio.registry.utils.kafka.AsyncProducer
- createTopics(Properties, Set<String>) - Static method in class io.apicurio.registry.utils.kafka.KafkaUtil
- createTopics(Properties, Set<String>, Map<String, String>) - Static method in class io.apicurio.registry.utils.kafka.KafkaUtil
-
Create topics with sensible defaults.
- createTopics(Admin, Set<String>) - Static method in class io.apicurio.registry.utils.kafka.KafkaUtil
- createTopics(Admin, Set<String>, Map<String, String>) - Static method in class io.apicurio.registry.utils.kafka.KafkaUtil
-
Create topics with sensible defaults.
- createTopicsAsync(Admin, Set<String>, Map<String, String>) - Static method in class io.apicurio.registry.utils.kafka.KafkaUtil
-
Create topics with sensible defaults, async.
I
- io.apicurio.registry.utils.kafka - package io.apicurio.registry.utils.kafka
K
- KafkaUtil - Class in io.apicurio.registry.utils.kafka
- KafkaUtil() - Constructor for class io.apicurio.registry.utils.kafka.KafkaUtil
P
- ProducerActions<K,V> - Interface in io.apicurio.registry.utils.kafka
R
- result(KafkaFuture<T>) - Static method in class io.apicurio.registry.utils.kafka.KafkaUtil
T
- toCompletionStage(KafkaFuture<T>) - Static method in class io.apicurio.registry.utils.kafka.KafkaUtil
All Classes All Packages