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: [email protected]
For additional commands, e-mail: [email protected]
