| commit | a775e95a39577c157ff27cbfa97317417aff9fd5 | [log] [tgz] |
|---|---|---|
| author | Marcin Czech <maczech@gmail.com> | Thu Jun 15 16:24:03 2023 +0200 |
| committer | Marcin Czech <maczech@gmail.com> | Thu Jun 29 10:50:31 2023 +0000 |
| tree | 191f8bf1490ee5d918a58c946de338a693086b15 | |
| parent | 4da780cf81fa6e8dae86cb04ba6dcae0c6ca03b6 [diff] |
Allow specifying failoverTimeMillis property for Kinesis consumer A worker which does not renew it's lease within this time interval will be regarded as having problems and it's shards will be assigned to other workers. Increasing failoverTimeMillis is suggested by AWS Support Team to avoid following issue: ``` java.lang.RuntimeException: java.lang.InterruptedException at software.amazon.kinesis.retrieval.polling.KinesisDataFetcher. getRecords(KinesisDataFetcher.java:336 ``` Bug: Issue 287304308 Change-Id: I9dbb79399d17b01e09d4cb672e83915b1909ec31
Provide producer and consumer of events streamed over AWS kinesis.
Information on how to build this plugin can be found here
Information on how to configure this plugin can be found here