public class FanOutRecordPublisherConfiguration extends Object
Constructor and Description |
---|
FanOutRecordPublisherConfiguration(Properties configProps,
List<String> streams)
Creates a FanOutRecordPublisherConfiguration.
|
Modifier and Type | Method and Description |
---|---|
Optional<String> |
getConsumerName()
Get consumer name, will be null if efo registration type is 'NONE'.
|
long |
getDeregisterStreamBaseBackoffMillis()
Get base backoff millis for the deregister stream operation.
|
java.time.Duration |
getDeregisterStreamConsumerTimeout()
Get maximum duration to wait for a stream consumer to deregister before giving up.
|
double |
getDeregisterStreamExpConstant()
Get exponential backoff power constant for the deregister stream operation.
|
long |
getDeregisterStreamMaxBackoffMillis()
Get maximum backoff millis for the deregister stream operation.
|
int |
getDeregisterStreamMaxRetries()
Get maximum retry attempts for the register stream operation.
|
long |
getDescribeStreamBaseBackoffMillis()
Get base backoff millis for the describe stream operation.
|
long |
getDescribeStreamConsumerBaseBackoffMillis()
Get base backoff millis for the describe stream operation.
|
double |
getDescribeStreamConsumerExpConstant()
Get exponential backoff power constant for the describe stream operation.
|
long |
getDescribeStreamConsumerMaxBackoffMillis()
Get maximum backoff millis for the describe stream operation.
|
int |
getDescribeStreamConsumerMaxRetries()
Get maximum retry attempts for the describe stream operation.
|
double |
getDescribeStreamExpConstant()
Get exponential backoff power constant for the describe stream operation.
|
long |
getDescribeStreamMaxBackoffMillis()
Get maximum backoff millis for the describe stream operation.
|
int |
getDescribeStreamMaxRetries()
Get maximum retry attempts for the describe stream operation.
|
ConsumerConfigConstants.EFORegistrationType |
getEfoRegistrationType()
Get efo registration type.
|
long |
getRegisterStreamBaseBackoffMillis()
Get base backoff millis for the register stream operation.
|
java.time.Duration |
getRegisterStreamConsumerTimeout()
Get maximum duration to wait for a stream consumer to become active before giving up.
|
double |
getRegisterStreamExpConstant()
Get exponential backoff power constant for the register stream operation.
|
long |
getRegisterStreamMaxBackoffMillis()
Get maximum backoff millis for the register stream operation.
|
int |
getRegisterStreamMaxRetries()
Get maximum retry attempts for the register stream operation.
|
Optional<String> |
getStreamConsumerArn(String stream)
Get the according consumer arn to the stream, will be null if efo registration type is 'LAZY'
or 'EAGER'.
|
long |
getSubscribeToShardBaseBackoffMillis()
Get base backoff millis for the subscribe to shard operation.
|
double |
getSubscribeToShardExpConstant()
Get exponential backoff power constant for the subscribe to shard operation.
|
long |
getSubscribeToShardMaxBackoffMillis()
Get maximum backoff millis for the subscribe to shard operation.
|
int |
getSubscribeToShardMaxRetries()
Get maximum retry attempts for the subscribe to shard operation.
|
java.time.Duration |
getSubscribeToShardTimeout()
Get timeout when waiting for a shard subscription to be established.
|
public FanOutRecordPublisherConfiguration(Properties configProps, List<String> streams)
configProps
- the configuration properties from config file.streams
- the streams which is sent to match the EFO consumer arn if the EFO
registration mode is set to `NONE`.public int getSubscribeToShardMaxRetries()
public java.time.Duration getSubscribeToShardTimeout()
public long getSubscribeToShardMaxBackoffMillis()
public long getSubscribeToShardBaseBackoffMillis()
public double getSubscribeToShardExpConstant()
public long getRegisterStreamBaseBackoffMillis()
public long getRegisterStreamMaxBackoffMillis()
public double getRegisterStreamExpConstant()
public int getRegisterStreamMaxRetries()
public java.time.Duration getRegisterStreamConsumerTimeout()
public long getDeregisterStreamBaseBackoffMillis()
public long getDeregisterStreamMaxBackoffMillis()
public double getDeregisterStreamExpConstant()
public int getDeregisterStreamMaxRetries()
public java.time.Duration getDeregisterStreamConsumerTimeout()
public int getDescribeStreamMaxRetries()
public long getDescribeStreamBaseBackoffMillis()
public long getDescribeStreamMaxBackoffMillis()
public double getDescribeStreamExpConstant()
public int getDescribeStreamConsumerMaxRetries()
public long getDescribeStreamConsumerBaseBackoffMillis()
public long getDescribeStreamConsumerMaxBackoffMillis()
public double getDescribeStreamConsumerExpConstant()
public ConsumerConfigConstants.EFORegistrationType getEfoRegistrationType()
public Optional<String> getConsumerName()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.