hampsterx/async-kinesis issues and pull requests

#35 - AttributeError("'AIOHTTPSession' object has no attribute 'close'")

Issue - State: open - Opened by tomharvey over 3 years ago

#34 - Set the PartitionKey when publishing records

Issue - State: open - Opened by tomharvey over 3 years ago - 3 comments

#33 - support for boto3 session

Pull Request - State: closed - Opened by hampsterx over 3 years ago

#32 - Support for boto3 session

Issue - State: closed - Opened by collinarnett over 3 years ago

#31 - Possibility to define Timestamp value for AT_TIMESTAMP iterator type

Pull Request - State: closed - Opened by bpyszkowski over 3 years ago - 2 comments

#30 - Allow graceful shutdown when task is cancelled

Pull Request - State: closed - Opened by chekan-o over 3 years ago - 1 comment

#29 - consumer: KeyError: 'NextShardIterator' after shard scale-up

Issue - State: closed - Opened by zarnovican almost 4 years ago - 4 comments

#28 - reshard test

Pull Request - State: closed - Opened by hampsterx almost 4 years ago - 2 comments

#27 - Does skip_describe_stream actually skip anything?

Issue - State: open - Opened by akursar about 4 years ago - 2 comments

#26 - Confirm NextShardIterator key exist to fetch from existing consumer shard

Pull Request - State: open - Opened by jmcgrath207 about 4 years ago - 12 comments

#25 - feat: support max_size in KPLAggregator

Pull Request - State: closed - Opened by akursar about 4 years ago

#24 - dont try reconnect if stream doesnt exist

Pull Request - State: closed - Opened by hampsterx about 4 years ago - 1 comment

#23 - consumer skip trying to checkpoint binary items

Pull Request - State: closed - Opened by hampsterx about 4 years ago

#22 - Unable to deserialize to non-iterable objects

Issue - State: closed - Opened by akursar about 4 years ago - 1 comment

#21 - feat: add KPL Aggregated Record aggregation

Pull Request - State: closed - Opened by akursar about 4 years ago - 1 comment

#20 - refactored flush method in producer and added connection error retry and backoff

Pull Request - State: closed - Opened by jmcgrath207 over 4 years ago - 6 comments

#19 - updated dependencies and made setup.py less restrictive

Pull Request - State: closed - Opened by jmcgrath207 over 4 years ago

#18 - Remove dependency on contextlib import AsyncExitStack

Pull Request - State: closed - Opened by jmcgrath207 over 4 years ago - 4 comments

#17 - fix: added missing re-raise

Pull Request - State: closed - Opened by zarnovican over 4 years ago

#16 - Add JsonListProcessor

Pull Request - State: closed - Opened by jmcgrath207 over 4 years ago - 2 comments

#15 - fix for aiobotocore

Pull Request - State: closed - Opened by hampsterx over 4 years ago

#14 - Consumer' object is not iterable

Issue - State: closed - Opened by jmcgrath207 over 4 years ago - 2 comments

#13 - misc upgrades

Pull Request - State: closed - Opened by hampsterx almost 5 years ago

#12 - fix for aggregator causing extra throttling

Pull Request - State: closed - Opened by hampsterx about 5 years ago

#11 - flag to skip describe stream for short lived producers

Pull Request - State: closed - Opened by hampsterx about 5 years ago