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 |
|---|---|
int |
getBatchBytes() |
java.nio.charset.Charset |
getCharset() |
ProducerMetadata.CompressionType |
getCompressionType() |
java.lang.Class<K> |
getKeyClassType() |
org.apache.kafka.common.serialization.Serializer<K> |
getKeySerializer() |
kafka.producer.Partitioner |
getPartitioner() |
int |
getSendTimeout() |
java.lang.String |
getTopic() |
java.lang.Class<V> |
getValueClassType() |
org.apache.kafka.common.serialization.Serializer<V> |
getValueSerializer() |
boolean |
isSync() |
void |
setBatchBytes(int batchBytes) |
void |
setCharset(java.nio.charset.Charset charset)
The character encoding to preform
String <-> byte[] conversion
instead of general (de)serialization. |
void |
setCompressionType(ProducerMetadata.CompressionType compressionType) |
void |
setPartitioner(kafka.producer.Partitioner partitioner) |
void |
setSendTimeout(int sendTimeout) |
void |
setSync(boolean sync) |
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 int getSendTimeout()
public void setSendTimeout(int sendTimeout)
public boolean isSync()
public void setSync(boolean sync)
public java.nio.charset.Charset getCharset()
public void setCharset(java.nio.charset.Charset charset)
String <-> byte[] conversion
instead of general (de)serialization.charset - the charset encoding to use.public java.lang.String toString()
toString in class java.lang.Object