Google Git
Sign in
gerrit / plugins / events-aws-kinesis / b90571067a6f5f268f0e17062d0e783b5bf7f2b4
commitb90571067a6f5f268f0e17062d0e783b5bf7f2b4[log] [tgz]
authorAntonio Barone <syntonyze@gmail.com>Tue Mar 05 13:35:20 2024 +0100
committerAntonio Barone <syntonyze@gmail.com>Thu Mar 28 16:57:42 2024 +0100
tree5963d97ae53ec85c1d5a8ab395c0a7fa0c1fbfe3
parent05b6542893eefa28139b8a14509afce5e4393fb3 [diff]
Adapt to the latest BrokerApi interface

The latest BrokerApiInterface requires the implementation of three
new interfaces :

- receiveAsync(String streamName, String groupId, Consumer<Event> consumer)
- disconnect(String topic, String groupId)
- Set<TopicSubscriberWithGroupId> topicSubscribersWithGroupId()

Implement the above interfaces for kinesis, so that kinesis streams
subscriptions can be managed by providing an explicit GroupId.

Bug: Issue 327473326
Change-Id: I5f5849c1ffd0a4a3a760794aae4589e99cff0cee
6 files changed
tree: 5963d97ae53ec85c1d5a8ab395c0a7fa0c1fbfe3
  1. src/
  2. BUILD
  3. external_plugin_deps.bzl
  4. Jenkinsfile
  5. LICENSE
  6. 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