Sajjad Moradi

Zookeeper Transaction

1

There are places in the code base in which multiple write interactions with ZK is done as a part of one operation. If any of these interactions fails or if...

Kafka 2.0 implementation of `StreamMetadataProvider.fetchStreamPartitionOffset()` returns the next offset after the last available offset while all other implementations correctly return the last available offset. This needs to be fixed. This...

Multi-Stream Consumption

2

Currently one realtime Pinot table only consumes from one stream. For use cases in which multiple existing streams are the input source for one Pinot table, the workaround is to...

Pauseless Consumption

16

# Background Currently when commit protocol starts for a partition, the realtime server stops consumption and till the new consuming->online helix message for the next consuming segment arrives, messages are...