K - the key type.V - the value type.public class DefaultKafkaProducerFactory<K,V> extends java.lang.Object implements ProducerFactory<K,V>, org.springframework.context.Lifecycle, org.springframework.beans.factory.DisposableBean
ProducerFactory implementation for the singleton shared Producer
instance.
This implementation will produce a new Producer instance
for provided Map configs and optional Serializer keySerializer,
valueSerializer implementations on each createProducer()
invocation.
The Producer instance is freed from the external Producer.close() invocation
with the internal wrapper. The real Producer.close() is called on the target
Producer during the Lifecycle.stop() or DisposableBean.destroy().
| Constructor and Description |
|---|
DefaultKafkaProducerFactory(java.util.Map<java.lang.String,java.lang.Object> configs) |
DefaultKafkaProducerFactory(java.util.Map<java.lang.String,java.lang.Object> configs,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer) |
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.kafka.clients.producer.KafkaProducer<K,V> |
createKafkaProducer() |
org.apache.kafka.clients.producer.Producer<K,V> |
createProducer() |
void |
destroy() |
boolean |
isRunning() |
void |
setKeySerializer(org.apache.kafka.common.serialization.Serializer<K> keySerializer) |
void |
setValueSerializer(org.apache.kafka.common.serialization.Serializer<V> valueSerializer) |
void |
start() |
void |
stop() |
public DefaultKafkaProducerFactory(java.util.Map<java.lang.String,java.lang.Object> configs)
public void setKeySerializer(org.apache.kafka.common.serialization.Serializer<K> keySerializer)
public void setValueSerializer(org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
public void destroy()
throws java.lang.Exception
destroy in interface org.springframework.beans.factory.DisposableBeanjava.lang.Exceptionpublic void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic org.apache.kafka.clients.producer.Producer<K,V> createProducer()
createProducer in interface ProducerFactory<K,V>