THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The FlinkKinesisConsumer is configured via Java Properties allowing arbitrary properties to be supported without breaking existing applications. The properties object is passed to the constructor of the consumer. The following properties will be added to support the two consumption options. Property keys are inline with current Flink naming conventions and will be exposed via constants:
| Key | Description | Type | Default |
| flink.stream.recordpublisher | Select RecordPublisher mechanism (efo|polling) | string | polling |
| flink.stream.efo.consumername | The name of the consumer to register with KDS | string | *see below |
| flink.stream.registerstreamconsumer.maxretries | Maximum number of attempts after recoverable exception | int | 10 |
| flink.stream.registerstreamconsumer.backoff.base | The base backoff time between attempts | long | 200 |
| flink.stream.registerstreamconsumer.backoff.max | The maximum backoff time between attempts | long | 1000 |
| flink.stream.registerstreamconsumer.backoff.expconst | The power constant for exponential backoff between attempts | double | 1.5 |
| flink.stream.deregisterstreamconsumer.maxretries | Maximum number of attempts after recoverable exception | int | 10 |
| flink.stream.deregisterstreamconsumer.backoff.base | The base backoff time between attempts | long | 200 |
| flink.stream.deregisterstreamconsumer.backoff.max | The maximum backoff time between attempts | long | 1000 |
| flink.stream.deregisterstreamconsumer.backoff.expconst | The power constant for exponential backoff between attempts | double | 1.5 |
| flink.stream.liststreamconsumers.maxretries | Maximum number of attempts after recoverable exception | int | 10 |
| flink.stream.liststreamconsumers.backoff.base | The base backoff time between attempts | long | 200 |
| flink.stream.liststreamconsumers.backoff.max | The maximum backoff time between attempts | long | 1000 |
| flink.stream.liststreamconsumers.backoff.expconst | The power constant for exponential backoff between attempts | double | 1.5 |
| flink.shard.subscribetoshard.maxretries | Maximum number of attempts after recoverable exception | int | 5 |
| flink.shard.subscribetoshard.backoff.base | The base backoff time between attempts | long | 1000 |
| flink.shard.subscribetoshard.backoff.max | The maximum backoff time between attempts | long | 2000 |
| flink.shard.subscribetoshard.backoff.expconst | The power constant for exponential backoff between attempts | double | 1.5 |
* No default. Provided by customer application
...