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

Reply via email to