Class KafkaProducerCacheUtils

java.lang.Object

io.confluent.kafkarest.auth.KafkaProducerCacheUtils

public class KafkaProducerCacheUtils
extends Object

Method Summary

Modifier and Type	Method	Description
static 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)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getProducerCallable

public 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)

getProducerCallable

public static Callable<ReferenceCountingHolder<org.apache.kafka.clients.producer.Producer<byte[],byte[]>>> getProducerCallable(Map<String,Object> configs)