org.springframework.integration.kafka.support
Class ProducerMetadata<K,V>
java.lang.Object
org.springframework.integration.kafka.support.ProducerMetadata<K,V>
- All Implemented Interfaces:
- org.springframework.beans.factory.InitializingBean
public class ProducerMetadata<K,V>
- extends java.lang.Object
- implements org.springframework.beans.factory.InitializingBean
- Since:
- 0.5
- Author:
- Soby Chacko, Rajasekar Elango
Methods inherited from class java.lang.Object |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
ProducerMetadata
public ProducerMetadata(java.lang.String topic)
getTopic
public java.lang.String getTopic()
getKeyEncoder
public kafka.serializer.Encoder<K> getKeyEncoder()
setKeyEncoder
public void setKeyEncoder(kafka.serializer.Encoder<K> keyEncoder)
getValueEncoder
public kafka.serializer.Encoder<V> getValueEncoder()
setValueEncoder
public void setValueEncoder(kafka.serializer.Encoder<V> valueEncoder)
getKeyClassType
public java.lang.Class<K> getKeyClassType()
setKeyClassType
public void setKeyClassType(java.lang.Class<K> keyClassType)
getValueClassType
public java.lang.Class<V> getValueClassType()
setValueClassType
public void setValueClassType(java.lang.Class<V> valueClassType)
getCompressionCodec
public java.lang.String getCompressionCodec()
setCompressionCodec
public void setCompressionCodec(java.lang.String compressionCodec)
getPartitioner
public kafka.producer.Partitioner getPartitioner()
setPartitioner
public void setPartitioner(kafka.producer.Partitioner partitioner)
afterPropertiesSet
public void afterPropertiesSet()
throws java.lang.Exception
- Specified by:
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
- Throws:
java.lang.Exception
isAsync
public boolean isAsync()
setAsync
public void setAsync(boolean async)
getBatchNumMessages
public java.lang.String getBatchNumMessages()
setBatchNumMessages
public void setBatchNumMessages(java.lang.String batchNumMessages)
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