public class ProducerMetadata<K,V>
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
ProducerMetadata.CompressionType |
Constructor and Description |
---|
ProducerMetadata(java.lang.String topic,
java.lang.Class<K> keyClassType,
java.lang.Class<V> valueClassType,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object obj) |
int |
getBatchBytes() |
ProducerMetadata.CompressionType |
getCompressionType() |
java.lang.Class<K> |
getKeyClassType() |
org.apache.kafka.common.serialization.Serializer<K> |
getKeySerializer() |
kafka.producer.Partitioner |
getPartitioner() |
java.lang.String |
getTopic() |
java.lang.Class<V> |
getValueClassType() |
org.apache.kafka.common.serialization.Serializer<V> |
getValueSerializer() |
int |
hashCode() |
void |
setBatchBytes(int batchBytes) |
void |
setCompressionType(ProducerMetadata.CompressionType compressionType) |
void |
setPartitioner(kafka.producer.Partitioner partitioner) |
java.lang.String |
toString() |
public java.lang.String getTopic()
public org.apache.kafka.common.serialization.Serializer<K> getKeySerializer()
public org.apache.kafka.common.serialization.Serializer<V> getValueSerializer()
public ProducerMetadata.CompressionType getCompressionType()
public void setCompressionType(ProducerMetadata.CompressionType compressionType)
public int getBatchBytes()
public void setBatchBytes(int batchBytes)
public kafka.producer.Partitioner getPartitioner()
public void setPartitioner(kafka.producer.Partitioner partitioner)
public java.lang.Class<K> getKeyClassType()
public java.lang.Class<V> getValueClassType()
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object