public class ProducerConfiguration<K,V>
extends java.lang.Object
| Constructor and Description |
|---|
ProducerConfiguration(ProducerMetadata<K,V> producerMetadata,
org.apache.kafka.clients.producer.Producer<K,V> producer) |
| Modifier and Type | Method and Description |
|---|---|
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> |
convertAndSend(java.lang.String topic,
java.lang.Integer partition,
java.lang.Object messageKey,
java.lang.Object messagePayload) |
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> |
convertAndSend(java.lang.String topic,
java.lang.Object messageKey,
java.lang.Object messagePayload) |
ProducerMetadata<K,V> |
getProducerMetadata() |
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> |
send(java.lang.String topic,
java.lang.Integer partition,
K messageKey,
V messagePayload) |
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> |
send(java.lang.String topic,
K messageKey,
V messagePayload) |
void |
setConversionService(org.springframework.core.convert.ConversionService conversionService) |
void |
setProducerListener(ProducerListener producerListener) |
void |
stop() |
java.lang.String |
toString() |
public ProducerConfiguration(ProducerMetadata<K,V> producerMetadata, org.apache.kafka.clients.producer.Producer<K,V> producer)
public void setConversionService(org.springframework.core.convert.ConversionService conversionService)
public void setProducerListener(ProducerListener producerListener)
public ProducerMetadata<K,V> getProducerMetadata()
public java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> send(java.lang.String topic,
K messageKey,
V messagePayload)
public java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> send(java.lang.String topic,
java.lang.Integer partition,
K messageKey,
V messagePayload)
public java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> convertAndSend(java.lang.String topic,
java.lang.Integer partition,
java.lang.Object messageKey,
java.lang.Object messagePayload)
public java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> convertAndSend(java.lang.String topic,
java.lang.Object messageKey,
java.lang.Object messagePayload)
public void stop()
public java.lang.String toString()
toString in class java.lang.Object