org.springframework.integration.kafka.support
Class ProducerConfiguration<K,V>
java.lang.Object
org.springframework.integration.kafka.support.ProducerConfiguration<K,V>
public class ProducerConfiguration<K,V>
- extends java.lang.Object
- Since:
- 0.5
Methods inherited from class java.lang.Object |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
ProducerConfiguration
public ProducerConfiguration(ProducerMetadata<K,V> producerMetadata,
kafka.javaapi.producer.Producer<K,V> producer)
getProducerMetadata
public ProducerMetadata<K,V> getProducerMetadata()
getProducer
public kafka.javaapi.producer.Producer<K,V> getProducer()
send
public void send(java.lang.String topic,
java.lang.Object messageKey,
org.springframework.messaging.Message<?> message)
throws java.lang.Exception
- Throws:
java.lang.Exception
equals
public boolean equals(java.lang.Object obj)
- Overrides:
equals
in class java.lang.Object
hashCode
public int hashCode()
- Overrides:
hashCode
in class java.lang.Object
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
stop
public void stop()