issues
search
twitchscience
/
kinsumer
Native Go consumer for AWS Kinesis streams.
Other
134
stars
35
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Remove DescribeStream from startup.
#67
ThisWillGoWell
closed
6 months ago
1
Add NextRaw funciton
#66
MarkSRobinson
opened
2 years ago
0
Add configuration option to start from timestamp
#65
aanari
closed
2 years ago
0
Add configuration option to start from timestamp
#64
colmsnowplow
closed
2 years ago
3
Filter which errors should be retried
#63
slydon
closed
3 years ago
1
added support for deaggregation for aggregated records
#62
psanzay
opened
3 years ago
1
Application Ids and Concurrent Apps using Kinsumer
#61
aldrinleal
opened
3 years ago
1
Improve aws error rendering
#60
WillSewell
closed
3 years ago
0
Debugging ConditionalCheckFailed
#59
mthssdrbrg
closed
3 years ago
2
add ResetCheckpoints function
#58
frrad
closed
2 years ago
1
<InvalidSignatureException message>Credential should be scoped to correct service: 'kinesis'
#57
pradeepkusingh
opened
4 years ago
1
batch processing
#56
jney
closed
3 years ago
1
Blocked at `.Next()`
#55
jney
closed
4 years ago
2
Allow dynamodb to be updating
#54
slydon
closed
4 years ago
0
Paginate when calling ListShards
#53
teamdoug
closed
4 years ago
0
Using kinsumer cross aws accounts delays/ lose the data
#52
rhythmsharma
opened
4 years ago
6
kinsumer doesn't update with new iterator after 5 mins
#51
donginseattle
opened
4 years ago
2
Refactor shard_consumer and handle expired iterators
#50
FugiTech
opened
4 years ago
0
Add Manual Checkpointing
#49
FugiTech
opened
4 years ago
10
Issue reading kinesis stream across different aws accounts
#48
rhythmsharma
closed
4 years ago
2
move from `github.com/twinj/uuid` to `github.com/google/uuid`
#47
taraspos
closed
4 years ago
2
use google uuid; add module
#46
brenol
closed
4 years ago
6
problem with using module in this package
#45
brenol
closed
4 years ago
1
Updates statsd.NewClient to statsd.NewClientWithConfig
#44
garethlewin
closed
5 years ago
0
Allow users to use ListShards to check Kinesis stream readiness
#43
StevenMcVicker
closed
6 months ago
4
kenesisStreamReady produces LimitExceededException when calling DescribeStream
#42
StevenMcVicker
opened
5 years ago
2
Manual commit checkpoint to ddb table
#41
alllomancer
opened
5 years ago
0
allow users to change initial stream position
#40
brenol
opened
5 years ago
0
De-aggregation of records
#39
kapadiakunal
opened
5 years ago
1
added a method to get back the record and not just the record data
#38
alllomancer
opened
5 years ago
0
added a method to get back the record and not just the record data
#37
alllomancer
closed
5 years ago
0
Enhanced Fan-Out
#36
nickpoorman
closed
3 months ago
2
Error using the same application name in two different streams
#35
abhijeetDunzo
closed
5 years ago
2
Use namespace in the dynamodb table
#34
Sytten
opened
5 years ago
2
Add logger interface
#33
Sytten
closed
5 years ago
1
Expose the logger
#32
Sytten
closed
5 years ago
0
how to define initial position in stream
#31
jney
opened
5 years ago
6
non stop ConditionalCheckFailedException error
#30
jney
opened
5 years ago
17
Calling Stop on a stopped consumer blocks
#29
Sytten
opened
5 years ago
3
Manually update checkpoint
#28
Sytten
opened
5 years ago
3
What should user do when Next() returns an error?
#27
bryanpaluch
closed
5 years ago
3
Allow UPDATING stream status
#26
teamdoug
closed
5 years ago
0
Travis build does not seem to be working correctly
#25
mikemoate
closed
5 years ago
1
Add a delay to let kinesalite calm down
#24
garethlewin
closed
5 years ago
0
Update travis
#23
garethlewin
closed
5 years ago
0
Fetch shard IDs from Kinesis if DynamoDB cache is empty
#22
dcelasun
closed
5 years ago
5
Replace DescribeStream with ListShards
#21
dcelasun
closed
5 years ago
2
Fix data race around leader handling
#20
dcelasun
closed
5 years ago
5
Data race during Stop()
#19
dcelasun
closed
5 years ago
0
Skip shard ID cache on first run
#18
dcelasun
closed
5 years ago
2
Next