public class KafkaProducerContext<K,V>
extends java.lang.Object
implements org.springframework.beans.factory.BeanFactoryAware
| Constructor and Description |
|---|
KafkaProducerContext() |
| Modifier and Type | Method and Description |
|---|---|
java.util.Properties |
getProducerProperties() |
ProducerConfiguration<K,V> |
getTopicConfiguration(java.lang.String topic) |
java.util.Map<java.lang.String,ProducerConfiguration<K,V>> |
getTopicsConfiguration() |
void |
send(org.springframework.messaging.Message<?> message) |
void |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setProducerProperties(java.util.Properties producerProperties) |
public void send(org.springframework.messaging.Message<?> message)
throws java.lang.Exception
java.lang.Exceptionpublic ProducerConfiguration<K,V> getTopicConfiguration(java.lang.String topic)
public java.util.Map<java.lang.String,ProducerConfiguration<K,V>> getTopicsConfiguration()
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
throws org.springframework.beans.BeansException
setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAwareorg.springframework.beans.BeansExceptionpublic void setProducerProperties(java.util.Properties producerProperties)
producerProperties - The producerProperties to set.public java.util.Properties getProducerProperties()