org.springframework.integration.kafka.support
Class ProducerMetadata<K,V>

java.lang.Object
  extended by 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

Constructor Summary
ProducerMetadata(java.lang.String topic)
           
 
Method Summary
 void afterPropertiesSet()
           
 boolean equals(java.lang.Object obj)
           
 java.lang.String getBatchNumMessages()
           
 java.lang.String getCompressionCodec()
           
 java.lang.Class<K> getKeyClassType()
           
 kafka.serializer.Encoder<K> getKeyEncoder()
           
 kafka.producer.Partitioner getPartitioner()
           
 java.lang.String getTopic()
           
 java.lang.Class<V> getValueClassType()
           
 kafka.serializer.Encoder<V> getValueEncoder()
           
 int hashCode()
           
 boolean isAsync()
           
 void setAsync(boolean async)
           
 void setBatchNumMessages(java.lang.String batchNumMessages)
           
 void setCompressionCodec(java.lang.String compressionCodec)
           
 void setKeyClassType(java.lang.Class<K> keyClassType)
           
 void setKeyEncoder(kafka.serializer.Encoder<K> keyEncoder)
           
 void setPartitioner(kafka.producer.Partitioner partitioner)
           
 void setValueClassType(java.lang.Class<V> valueClassType)
           
 void setValueEncoder(kafka.serializer.Encoder<V> valueEncoder)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ProducerMetadata

public ProducerMetadata(java.lang.String topic)
Method Detail

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