tree 5963d97ae53ec85c1d5a8ab395c0a7fa0c1fbfe3
parent 05b6542893eefa28139b8a14509afce5e4393fb3
author Antonio Barone <syntonyze@gmail.com> 1709642120 +0100
committer Antonio Barone <syntonyze@gmail.com> 1711641462 +0100

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