A C I K P R T 
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
 
A C I K P R T 
All Classes All Packages