public class ConsumerProperties extends Object implements MergableProperties
Constructor and Description |
---|
ConsumerProperties() |
Modifier and Type | Method and Description |
---|---|
@Min(value=1L,message="Backoff initial interval should be greater than zero.") int |
getBackOffInitialInterval() |
@Min(value=1L,message="Backoff max interval should be greater than zero.") int |
getBackOffMaxInterval() |
@Min(value=1L,message="Backoff multiplier should be greater than zero.") double |
getBackOffMultiplier() |
@Min(value=1L,message="Concurrency should be greater than zero.") int |
getConcurrency() |
HeaderMode |
getHeaderMode() |
@Min(value=1L,message="Instance count should be greater than zero.") int |
getInstanceCount() |
@Min(value=0L,message="Instance index should be greater than or equal to 0") int |
getInstanceIndex() |
@Min(value=1L,message="Max attempts should be greater than zero.") int |
getMaxAttempts() |
boolean |
isMultiplex() |
boolean |
isPartitioned() |
boolean |
isUseNativeDecoding() |
void |
setBackOffInitialInterval(int backOffInitialInterval) |
void |
setBackOffMaxInterval(int backOffMaxInterval) |
void |
setBackOffMultiplier(double backOffMultiplier) |
void |
setConcurrency(int concurrency) |
void |
setHeaderMode(HeaderMode headerMode) |
void |
setInstanceCount(int instanceCount) |
void |
setInstanceIndex(int instanceIndex) |
void |
setMaxAttempts(int maxAttempts) |
void |
setMultiplex(boolean multiplex) |
void |
setPartitioned(boolean partitioned) |
void |
setUseNativeDecoding(boolean useNativeDecoding) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
copyProperties, merge
@Min(value=1L, message="Concurrency should be greater than zero.") public @Min(value=1L,message="Concurrency should be greater than zero.") int getConcurrency()
public void setConcurrency(int concurrency)
public boolean isPartitioned()
public void setPartitioned(boolean partitioned)
@Min(value=1L, message="Instance count should be greater than zero.") public @Min(value=1L,message="Instance count should be greater than zero.") int getInstanceCount()
public void setInstanceCount(int instanceCount)
@Min(value=0L, message="Instance index should be greater than or equal to 0") public @Min(value=0L,message="Instance index should be greater than or equal to 0") int getInstanceIndex()
public void setInstanceIndex(int instanceIndex)
@Min(value=1L, message="Max attempts should be greater than zero.") public @Min(value=1L,message="Max attempts should be greater than zero.") int getMaxAttempts()
public void setMaxAttempts(int maxAttempts)
@Min(value=1L, message="Backoff initial interval should be greater than zero.") public @Min(value=1L,message="Backoff initial interval should be greater than zero.") int getBackOffInitialInterval()
public void setBackOffInitialInterval(int backOffInitialInterval)
@Min(value=1L, message="Backoff max interval should be greater than zero.") public @Min(value=1L,message="Backoff max interval should be greater than zero.") int getBackOffMaxInterval()
public void setBackOffMaxInterval(int backOffMaxInterval)
@Min(value=1L, message="Backoff multiplier should be greater than zero.") public @Min(value=1L,message="Backoff multiplier should be greater than zero.") double getBackOffMultiplier()
public void setBackOffMultiplier(double backOffMultiplier)
public HeaderMode getHeaderMode()
public void setHeaderMode(HeaderMode headerMode)
public boolean isUseNativeDecoding()
public void setUseNativeDecoding(boolean useNativeDecoding)
public boolean isMultiplex()
public void setMultiplex(boolean multiplex)
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.