npawar opened a new pull request #6667:
URL: https://github.com/apache/incubator-pinot/pull/6667
## Description
#5648
Part 2 of Kinesis implementation changes. This #6518 is the main PR, which
is being split up into 3 parts in order to reduce the scope of review.
In this PR, An abstraction has been introduced for a group of
partition/shards, and each consumer will now be responsible for a
PartitionGroup instead of just a partitionId (though in first iteration, the
PartitionGroup will only contain 1 partition/shard). It includes corresponding
additions to interfaces and some new interfaces.
Kafka stream should function as is, with no changes needed.
## Release Notes
New interfaces and some additions to existing interfaces for Stream
Consumers.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
