public class KafkaProducerProperties extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KafkaProducerProperties.CompressionType |
Constructor and Description |
---|
KafkaProducerProperties() |
Modifier and Type | Method and Description |
---|---|
int |
getBatchTimeout() |
int |
getBufferSize() |
KafkaProducerProperties.CompressionType |
getCompressionType() |
Map<String,String> |
getConfiguration() |
boolean |
isSync() |
void |
setBatchTimeout(int batchTimeout) |
void |
setBufferSize(int bufferSize) |
void |
setCompressionType(KafkaProducerProperties.CompressionType compressionType) |
void |
setConfiguration(Map<String,String> configuration) |
void |
setSync(boolean sync) |
public int getBufferSize()
public void setBufferSize(int bufferSize)
@NotNull public KafkaProducerProperties.CompressionType getCompressionType()
public void setCompressionType(KafkaProducerProperties.CompressionType compressionType)
public boolean isSync()
public void setSync(boolean sync)
public int getBatchTimeout()
public void setBatchTimeout(int batchTimeout)
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.