K - the key type.V - the value type.public interface ProducerFactory<K,V>
Producer instance(s).| Modifier and Type | Method and Description |
|---|---|
default void |
closeProducerFor(java.lang.String transactionIdSuffix)
Remove the specified producer from the cache and close it.
|
org.apache.kafka.clients.producer.Producer<K,V> |
createProducer()
Create a producer.
|
default boolean |
isProducerPerConsumerPartition()
Return the producerPerConsumerPartition.
|
default boolean |
transactionCapable()
Return true if the factory supports transactions.
|
org.apache.kafka.clients.producer.Producer<K,V> createProducer()
default boolean transactionCapable()
default void closeProducerFor(java.lang.String transactionIdSuffix)
transactionIdSuffix - the producer's transaction id suffix.default boolean isProducerPerConsumerPartition()