Class KafkaProducerCacheUtils
java.lang.Object
io.confluent.kafkarest.auth.KafkaProducerCacheUtils
-
Method Summary
Modifier and TypeMethodDescriptionstatic Callable<ReferenceCountingHolder<org.apache.kafka.clients.producer.Producer<byte[], byte[]>>> getProducerCallable(Map<String, Object> configs) static Callable<ReferenceCountingHolder<org.apache.kafka.clients.producer.Producer<byte[], byte[]>>> getProducerCallable(Map<String, Object> configs, com.google.common.cache.Cache<Map.Entry<String, String>, org.apache.kafka.common.errors.ApiException> exceptionCache, String cacheKey)
-
Method Details
-
getProducerCallable
-
getProducerCallable
public static Callable<ReferenceCountingHolder<org.apache.kafka.clients.producer.Producer<byte[],byte[]>>> getProducerCallable(Map<String, Object> configs)
-