public class ProducerConfiguration<K,V>
extends java.lang.Object
| Constructor and Description |
|---|
ProducerConfiguration(ProducerMetadata<K,V> producerMetadata,
kafka.javaapi.producer.Producer<K,V> producer) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(java.lang.Object obj) |
ProducerMetadata<K,V> |
getProducerMetadata() |
int |
hashCode() |
void |
send(org.springframework.messaging.Message<?> message) |
java.lang.String |
toString() |
public ProducerConfiguration(ProducerMetadata<K,V> producerMetadata, kafka.javaapi.producer.Producer<K,V> producer)
public ProducerMetadata<K,V> getProducerMetadata()
public void send(org.springframework.messaging.Message<?> message)
throws java.lang.Exception
java.lang.Exceptionpublic boolean equals(java.lang.Object obj)
equals in class java.lang.Objectpublic int hashCode()
hashCode in class java.lang.Objectpublic java.lang.String toString()
toString in class java.lang.Object