Class ProducerConfigProperties.Batching

java.lang.Object

org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties.Batching

Enclosing class:

ProducerConfigProperties

public static class ProducerConfigProperties.Batching
extends Object

Author:

Chris Bono

Constructor Summary

Constructors

Constructor	Description
Batching()

Method Summary

Modifier and Type	Method	Description
Boolean	getEnabled()
DataSize	getMaxBytes()
Integer	getMaxMessages()
Duration	getMaxPublishDelay()
Integer	getPartitionSwitchFrequencyByPublishDelay()
void	setEnabled(Boolean enabled)
void	setMaxBytes(DataSize maxBytes)
void	setMaxMessages(Integer maxMessages)
void	setMaxPublishDelay(Duration maxPublishDelay)
void	setPartitionSwitchFrequencyByPublishDelay(Integer partitionSwitchFrequencyByPublishDelay)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Batching

public Batching()

Method Details

getMaxPublishDelay

public Duration getMaxPublishDelay()

setMaxPublishDelay

public void setMaxPublishDelay(Duration maxPublishDelay)

getPartitionSwitchFrequencyByPublishDelay

public Integer getPartitionSwitchFrequencyByPublishDelay()

setPartitionSwitchFrequencyByPublishDelay

public void setPartitionSwitchFrequencyByPublishDelay(Integer partitionSwitchFrequencyByPublishDelay)

getMaxMessages

public Integer getMaxMessages()

setMaxMessages

public void setMaxMessages(Integer maxMessages)

getMaxBytes

public DataSize getMaxBytes()

setMaxBytes

public void setMaxBytes(DataSize maxBytes)

getEnabled

public Boolean getEnabled()

setEnabled

public void setEnabled(Boolean enabled)