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) |
boolean |
equals(java.lang.Object obj) |
ProducerMetadata<K,V> |
getProducerMetadata() |
int |
hashCode() |
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 |
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 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 boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object
public void stop()