public class ProducerConfigurationData extends Object implements Serializable, Cloneable
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BATCHING_MAX_MESSAGES |
static int |
DEFAULT_MAX_PENDING_MESSAGES |
static int |
DEFAULT_MAX_PENDING_MESSAGES_ACROSS_PARTITIONS |
Constructor and Description |
---|
ProducerConfigurationData() |
Modifier and Type | Method and Description |
---|---|
long |
batchingPartitionSwitchFrequencyIntervalMicros() |
ProducerConfigurationData |
clone() |
boolean |
isEncryptionEnabled()
Returns true if encryption keys are added
|
void |
setBatchingMaxBytes(int batchingMaxBytes) |
void |
setBatchingMaxMessages(int batchingMaxMessages) |
void |
setBatchingMaxPublishDelayMicros(long batchDelay,
TimeUnit timeUnit) |
void |
setBatchingPartitionSwitchFrequencyByPublishDelay(int frequencyByPublishDelay) |
void |
setMaxPendingMessages(int maxPendingMessages) |
void |
setMaxPendingMessagesAcrossPartitions(int maxPendingMessagesAcrossPartitions) |
void |
setProducerName(String producerName) |
void |
setSendTimeoutMs(int sendTimeout,
TimeUnit timeUnit) |
public static final int DEFAULT_BATCHING_MAX_MESSAGES
public static final int DEFAULT_MAX_PENDING_MESSAGES
public static final int DEFAULT_MAX_PENDING_MESSAGES_ACROSS_PARTITIONS
public boolean isEncryptionEnabled()
public ProducerConfigurationData clone()
public void setProducerName(String producerName)
public void setMaxPendingMessages(int maxPendingMessages)
public void setMaxPendingMessagesAcrossPartitions(int maxPendingMessagesAcrossPartitions)
public void setBatchingMaxMessages(int batchingMaxMessages)
public void setBatchingMaxBytes(int batchingMaxBytes)
public void setSendTimeoutMs(int sendTimeout, TimeUnit timeUnit)
public void setBatchingMaxPublishDelayMicros(long batchDelay, TimeUnit timeUnit)
public void setBatchingPartitionSwitchFrequencyByPublishDelay(int frequencyByPublishDelay)
public long batchingPartitionSwitchFrequencyIntervalMicros()
Copyright © 2017–2020 Apache Software Foundation. All rights reserved.