commit	10059b43e0fd8aba261043ee0444dc2b2ba35a61	[log] [tgz]
author	Fabio Ponciroli <ponch78@gmail.com>	Tue Sep 20 15:58:54 2022 -0500
committer	Fabio Ponciroli <ponch78@gmail.com>	Thu Sep 22 10:22:05 2022 -0500
tree	0901ace52287eac4c9efb31371008ff48c7bc099
parent	ccf9e83ed0ab87eec4df6f74cc434eb10548db62 [diff]

Update checkpoint on regular bases

Currently checkpointing happens only at shutdown and at the end
of the stream. Allow more frequent checkpointing to avoid replaying
all the stream in case the kinesis collector is not stopped gracefully.

Bug: Issue 15321
Change-Id: I83096084a32773e585f5b7c264bc9ad286325dec

src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java[diff]
src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisRecordProcessor.java[diff]
src/main/resources/Documentation/Config.md[diff]
src/test/java/com/googlesource/gerrit/plugins/kinesis/KinesisRecordProcessorTest.java[diff]

4 files changed

tree: 0901ace52287eac4c9efb31371008ff48c7bc099

src/
BUILD
external_plugin_deps.bzl
Jenkinsfile
LICENSE
README.md

README.md

events-aws-kinesis

Provide producer and consumer of events streamed over AWS kinesis.

Build

Information on how to build this plugin can be found here

Configuration

Information on how to configure this plugin can be found here