public class ProducerMetadata<K,V>
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean
| Constructor and Description |
|---|
ProducerMetadata(java.lang.String topic) |
| Modifier and Type | Method and Description |
|---|---|
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<K> |
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<K> partitioner) |
void |
setValueClassType(java.lang.Class<V> valueClassType) |
void |
setValueEncoder(kafka.serializer.Encoder<V> valueEncoder) |
java.lang.String |
toString() |
public java.lang.String getTopic()
public kafka.serializer.Encoder<K> getKeyEncoder()
public void setKeyEncoder(kafka.serializer.Encoder<K> keyEncoder)
public kafka.serializer.Encoder<V> getValueEncoder()
public void setValueEncoder(kafka.serializer.Encoder<V> valueEncoder)
public java.lang.Class<K> getKeyClassType()
public void setKeyClassType(java.lang.Class<K> keyClassType)
public java.lang.Class<V> getValueClassType()
public void setValueClassType(java.lang.Class<V> valueClassType)
public java.lang.String getCompressionCodec()
public void setCompressionCodec(java.lang.String compressionCodec)
public kafka.producer.Partitioner<K> getPartitioner()
public void setPartitioner(kafka.producer.Partitioner<K> partitioner)
public void afterPropertiesSet()
throws java.lang.Exception
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanjava.lang.Exceptionpublic boolean isAsync()
public void setAsync(boolean async)
public java.lang.String getBatchNumMessages()
public void setBatchNumMessages(java.lang.String batchNumMessages)
public 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