Uses of Class
org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer

Packages that use DefaultKafkaProducerFactory.CloseSafeProducer

Package	Description
org.springframework.kafka.core	Package for kafka core components

Uses of DefaultKafkaProducerFactory.CloseSafeProducer in org.springframework.kafka.core

Methods in org.springframework.kafka.core that return types with arguments of type DefaultKafkaProducerFactory.CloseSafeProducer

Modifier and Type	Method	Description
protected BlockingQueue<DefaultKafkaProducerFactory.CloseSafeProducer<K,V>>	DefaultKafkaProducerFactory.getCache()
protected BlockingQueue<DefaultKafkaProducerFactory.CloseSafeProducer<K,V>>	DefaultKafkaProducerFactory.getCache(String txIdPrefix)

Methods in org.springframework.kafka.core with parameters of type DefaultKafkaProducerFactory.CloseSafeProducer

Modifier and Type	Method	Description
protected final boolean	DefaultKafkaProducerFactory.removeProducer(DefaultKafkaProducerFactory.CloseSafeProducer<K,V> producerToRemove, Duration timeout)	Remove the single shared producer and a thread-bound instance if present.