Class KafkaProducerCacheImpl

java.lang.Object

io.confluent.kafkarest.auth.KafkaProducerCacheImpl

All Implemented Interfaces:

KafkaProducerCache

public class KafkaProducerCacheImpl
extends Object
implements KafkaProducerCache

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EXCEPTION_CACHE_CAPACITY_CONFIG
static final int	EXCEPTION_CACHE_DEFAULT_CAPACITY
static final long	EXCEPTION_CACHE_DEFAULT_VALIDITY_MILLIS
static final String	EXCEPTION_CACHE_ENABLE_CONFIG
static final boolean	EXCEPTION_CACHE_ENABLE_DEFAULT
static final String	EXCEPTION_CACHE_VALIDITY_MILLIS_CONFIG
static final String	PRODUCER_CACHE_CAPACITY_CONFIG
static final int	PRODUCER_CACHE_DEFAULT_CAPACITY
static final long	PRODUCER_CACHE_DEFAULT_VALIDITY_MILLIS
static final String	PRODUCER_CACHE_TRACKING_USAGE_REFCOUNT_ENABLE_CONFIG	By disabling this flag, the Producer will be closed as soon as it is removed from the cache.
static final String	PRODUCER_CACHE_VALIDITY_MILLIS_CONFIG

Constructor Summary

Constructors

Constructor	Description
KafkaProducerCacheImpl(jakarta.inject.Provider<io.confluent.kafkarest.KafkaRestConfig> configProvider)

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.producer.Producer<byte[],byte[]>	provide(String cacheKey, Map<String,Object> configs)

Methods inherited from class java.lang.Object

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

Field Details

PRODUCER_CACHE_CAPACITY_CONFIG

public static final String PRODUCER_CACHE_CAPACITY_CONFIG

See Also:

• Constant Field Values

PRODUCER_CACHE_VALIDITY_MILLIS_CONFIG

public static final String PRODUCER_CACHE_VALIDITY_MILLIS_CONFIG

See Also:

• Constant Field Values

PRODUCER_CACHE_DEFAULT_CAPACITY

public static final int PRODUCER_CACHE_DEFAULT_CAPACITY

See Also:

• Constant Field Values

PRODUCER_CACHE_DEFAULT_VALIDITY_MILLIS

public static final long PRODUCER_CACHE_DEFAULT_VALIDITY_MILLIS

See Also:

• Constant Field Values

PRODUCER_CACHE_TRACKING_USAGE_REFCOUNT_ENABLE_CONFIG

public static final String PRODUCER_CACHE_TRACKING_USAGE_REFCOUNT_ENABLE_CONFIG

By disabling this flag, the Producer will be closed as soon as it is removed from the cache. This is useful for remediating issues with the leaked Producer instances. On disabling this flag, PRODUCER_CACHE_VALIDITY_MILLIS_CONFIG should also being set to a higher value

See Also:

• Constant Field Values

EXCEPTION_CACHE_ENABLE_CONFIG

public static final String EXCEPTION_CACHE_ENABLE_CONFIG

See Also:

• Constant Field Values

EXCEPTION_CACHE_CAPACITY_CONFIG

public static final String EXCEPTION_CACHE_CAPACITY_CONFIG

See Also:

• Constant Field Values

EXCEPTION_CACHE_VALIDITY_MILLIS_CONFIG

public static final String EXCEPTION_CACHE_VALIDITY_MILLIS_CONFIG

See Also:

• Constant Field Values

EXCEPTION_CACHE_DEFAULT_CAPACITY

public static final int EXCEPTION_CACHE_DEFAULT_CAPACITY

See Also:

• Constant Field Values

EXCEPTION_CACHE_DEFAULT_VALIDITY_MILLIS

public static final long EXCEPTION_CACHE_DEFAULT_VALIDITY_MILLIS

See Also:

• Constant Field Values

EXCEPTION_CACHE_ENABLE_DEFAULT

public static final boolean EXCEPTION_CACHE_ENABLE_DEFAULT

See Also:

• Constant Field Values

Constructor Details

KafkaProducerCacheImpl

@Inject
public KafkaProducerCacheImpl(jakarta.inject.Provider<io.confluent.kafkarest.KafkaRestConfig> configProvider)

Method Details

provide

public org.apache.kafka.clients.producer.Producer<byte[],byte[]> provide(String cacheKey,
 Map<String,Object> configs)

Specified by:

provide in interface KafkaProducerCache