public class ProducerProperties extends Object implements MergableProperties
Constructor and Description |
---|
ProducerProperties() |
Modifier and Type | Method and Description |
---|---|
HeaderMode |
getHeaderMode() |
@Min(value=1L,message="Partition count should be greater than zero.") int |
getPartitionCount() |
org.springframework.expression.Expression |
getPartitionKeyExpression() |
Class<?> |
getPartitionKeyExtractorClass()
Deprecated.
|
String |
getPartitionKeyExtractorName() |
Class<?> |
getPartitionSelectorClass()
Deprecated.
|
org.springframework.expression.Expression |
getPartitionSelectorExpression() |
String |
getPartitionSelectorName() |
String[] |
getRequiredGroups() |
boolean |
isErrorChannelEnabled() |
boolean |
isPartitioned() |
boolean |
isUseNativeEncoding() |
@AssertTrue(message="Partition key expression and partition key extractor class properties are mutually exclusive.") boolean |
isValidPartitionKeyProperty() |
@AssertTrue(message="Partition selector class and partition selector expression properties are mutually exclusive.") 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)
Deprecated.
|
void |
setPartitionKeyExtractorName(String partitionKeyExtractorName) |
void |
setPartitionSelectorClass(Class<?> partitionSelectorClass)
Deprecated.
|
void |
setPartitionSelectorExpression(org.springframework.expression.Expression partitionSelectorExpression) |
void |
setPartitionSelectorName(String partitionSelectorName) |
void |
setRequiredGroups(String... requiredGroups) |
void |
setUseNativeEncoding(boolean useNativeEncoding) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
copyProperties, merge
public org.springframework.expression.Expression getPartitionKeyExpression()
public void setPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression)
@Deprecated public Class<?> getPartitionKeyExtractorClass()
@Deprecated public void setPartitionKeyExtractorClass(Class<?> partitionKeyExtractorClass)
public boolean isPartitioned()
@Deprecated public Class<?> getPartitionSelectorClass()
@Deprecated 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 @Min(value=1L,message="Partition count should be greater than zero.") 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 @AssertTrue(message="Partition key expression and partition key extractor class properties are mutually exclusive.") boolean isValidPartitionKeyProperty()
@AssertTrue(message="Partition selector class and partition selector expression properties are mutually exclusive.") public @AssertTrue(message="Partition selector class and partition selector expression properties are mutually exclusive.") 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)
public String getPartitionKeyExtractorName()
public void setPartitionKeyExtractorName(String partitionKeyExtractorName)
public String getPartitionSelectorName()
public void setPartitionSelectorName(String partitionSelectorName)
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.