This is an automated email from the ASF dual-hosted git repository. xiangfu pushed a change to branch sharded_consumer_type_support_with_kinesis in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
at 063a06f fixing compilation This branch includes the following new commits: new abc6588 Add interfaces for V2 consumers new 60195b0 Add initial implementation of Kinesis consumer new 1a8a80a Add PartitionGroupMetdataMap interface new 76cfcf1 Add kinesis code to handle offsets new 56efa08 Refactor PartitionGroupMetadataMap interface new c9cd79c Refactor kinesis shard metadata interface and add shardId to the metadata new ba3d100 Fix consumer code new 9567c18 Move shardId out of checkpoint to partition group metadata new 2463bd1 Reformat code new ee95eeb Add license headers new b0eeec6 Add Kinesis config wrapper new 900450d fetch records with timeout new 422688d Add license header new b0a2468 Handle exceptions new 00db7a2 Refactor code new bb8e08f Handle closed connections new 47b1664 Refactor: get shard iterator methods new dbdcaf0 Change shard metadata logic new d922695 Add test code for kinesis new 203aa08 Handle timeout exception in consumer and make shard iterator type configurable new 8d0248a Add isEndOfPartition check in checkpoints new 4da5a2c Return message batch instead of list in the fetch result new 063a06f fixing compilation The 23 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org