public class ProducerProperties extends Object
Constructor and Description |
---|
ProducerProperties() |
Modifier and Type | Method and Description |
---|---|
HeaderMode |
getHeaderMode() |
int |
getPartitionCount() |
org.springframework.expression.Expression |
getPartitionKeyExpression() |
Class<?> |
getPartitionKeyExtractorClass() |
Class<?> |
getPartitionSelectorClass() |
org.springframework.expression.Expression |
getPartitionSelectorExpression() |
String[] |
getRequiredGroups() |
boolean |
isErrorChannelEnabled() |
boolean |
isPartitioned() |
boolean |
isUseNativeEncoding() |
boolean |
isValidPartitionKeyProperty() |
boolean |
isValidPartitionSelectorProperty() |
void |
setErrorChannelEnabled(boolean errorChannelEnabled) |
void |
setHeaderMode(HeaderMode headerMode) |
void |
setPartitionCount(int partitionCount) |
void |
setPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression) |
void |
setPartitionKeyExtractorClass(Class<?> partitionKeyExtractorClass) |
void |
setPartitionSelectorClass(Class<?> partitionSelectorClass) |
void |
setPartitionSelectorExpression(org.springframework.expression.Expression partitionSelectorExpression) |
void |
setRequiredGroups(String... requiredGroups) |
void |
setUseNativeEncoding(boolean useNativeEncoding) |
public org.springframework.expression.Expression getPartitionKeyExpression()
public void setPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression)
public Class<?> getPartitionKeyExtractorClass()
public void setPartitionKeyExtractorClass(Class<?> partitionKeyExtractorClass)
public boolean isPartitioned()
public Class<?> getPartitionSelectorClass()
public void setPartitionSelectorClass(Class<?> partitionSelectorClass)
public org.springframework.expression.Expression getPartitionSelectorExpression()
public void setPartitionSelectorExpression(org.springframework.expression.Expression partitionSelectorExpression)
@Min(value=1L, message="Partition count should be greater than zero.") public int getPartitionCount()
public void setPartitionCount(int partitionCount)
public String[] getRequiredGroups()
public void setRequiredGroups(String... requiredGroups)
@AssertTrue(message="Partition key expression and partition key extractor class properties are mutually exclusive.") public boolean isValidPartitionKeyProperty()
@AssertTrue(message="Partition selector class and partition selector expression properties are mutually exclusive.") public boolean isValidPartitionSelectorProperty()
public HeaderMode getHeaderMode()
public void setHeaderMode(HeaderMode headerMode)
public boolean isUseNativeEncoding()
public void setUseNativeEncoding(boolean useNativeEncoding)
public boolean isErrorChannelEnabled()
public void setErrorChannelEnabled(boolean errorChannelEnabled)
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.