public class ProducerProperties extends Object implements MergableProperties
Type | Property and Description |
---|---|
@AssertTrue(message="Partition key expression and partition key extractor class properties are mutually exclusive.") boolean |
isValidPartitionKey
Gets the value of the property validPartitionKeyProperty.
|
@AssertTrue(message="Partition selector class and partition selector expression properties are mutually exclusive.") boolean |
isValidPartitionSelector
Gets the value of the property validPartitionSelectorProperty.
|
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()
Gets the value of the property validPartitionKeyProperty.
|
@AssertTrue(message="Partition selector class and partition selector expression properties are mutually exclusive.") boolean |
isValidPartitionSelectorProperty()
Gets the value of the property validPartitionSelectorProperty.
|
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
@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 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 © 2018 Pivotal Software, Inc.. All rights reserved.