harlow/kinesis-consumer

Issues

• Retryable errors don't get retried in master

  #152 opened 3 months ago by jtackaberry
  1

• Enhanced Fan-Out

  #97 opened 6 months ago by nickpoorman
  0

• ProvisionedThroughputExceededException Error

  #158 opened 7 months ago by chenyin0126
  3

• aws sdk v2 upgrade

  #145 opened 2 years ago by polanskya
  3

• Compile Time Error When Starting Consumer With Kinesis Client

  #154 opened a year ago by nathanglb
  3

• ListShards Failure With Large Number of Shards

  #109 opened 5 years ago by jasonpepper
  2

• Release master changes

  #151 opened 2 years ago by ODudek
  0

• where did version v0.3.6-0.20210911031324-5a873d6e9fec go?

  #147 opened 2 years ago by timo
  3

• read: connection reset by peer

  #149 opened 2 years ago by jporcelli1120
  0

• multiple clients

  #114 opened 5 years ago by jney
  7

• Signiture change for kinesis WithClient()

  #143 opened 3 years ago by SeenYang
  6

• Error when saving to DynamoDB

  #142 opened 3 years ago by tiagomelo
  3

• Update to or support AWS SDK v2

  #138 opened 3 years ago by akrantz01
  4

• Convert tests to use Docker Compose

  #140 opened 3 years ago by harlow
  0

• ErrSkipCheckpoint is not functioning

  #136 opened 3 years ago by AkiraTamai
  2

• [Question] Shard Closed Information

  #133 opened 3 years ago by jonandrewj
  6

• Add the ability to handle more errors without closing the consumer

  #131 opened 4 years ago by jonandrewj
  1

• Interval Batching for Separate Callback Function

  #128 opened 4 years ago by epociask
  2

• Consumer (possibly) stuck if sequence # refers to expired data

  #125 opened 4 years ago by jtackaberry
  1

• PutRecords

  #112 opened 4 years ago by jney
  5

• How to obtain ShardID from within ScanFunc?

  #120 opened 4 years ago by jtackaberry
  5

• Update aws-sdk-go to at least v1.23.13 for OIDC web identity token

  #117 opened 4 years ago by mycrEEpy
  1

• undefined functions -- consumer.WithMaxRecords and consumer.WithScanInterval

  #115 opened 4 years ago by prashantssingh
  4

• The timestampInMillis parameter cannot be greater than the currentTimestampInMillis

  #116 opened 4 years ago by adamcypher
  1

• support for multiple consumers across shards

  #42 opened 7 years ago by bryanpaluch
  8

• Kinesis sharIterator does not recover when out of retention period

  #98 opened 5 years ago by sauraz-zz
  1

• Checkpoint Set Error Causes Scan to Exit

  #93 opened 6 years ago by jasonpepper
  1

• checkpoint error: ValidationException: The provided key element does not match the schema

  #111 opened 5 years ago by pradeepkusingh
  0

• Unable to get external REDIS working

  #107 opened 5 years ago by pradeepkusingh
  0

• Is it possible to increase the polling time??

  #108 opened 5 years ago by pradeepkusingh
  1

• Use aws api that accepts context as first parameter. Opentracing integration requires context as first parameter for propagation

  #67 opened 6 years ago by etsangsplk
  5

• in-memory checkpoint?

  #101 opened 5 years ago by ashanbrown
  1

• Add integration tests with kinesalite

  #76 opened 5 years ago by harlow
  1

• It wont work if I have no permissions to ListShardsInput

  #94 opened 5 years ago by dema501
  3

• GetRecords Errors are Masked

  #92 opened 5 years ago by jasonpepper
  1

• Document the starting place for consumer on stream

  #86 opened 6 years ago by harlow
  0

• Scan function should poll stream and re-balance new shards

  #36 opened 6 years ago by harlow
  5

• Start from the ending of the stream each time

  #84 opened 6 years ago by CcccFz
  2

• Add options for db number in the redis checkpoint?

  #79 opened 6 years ago by fuzzy31u
  3

• Refactor the Scan public interface

  #75 opened 6 years ago by harlow
  6

• Cancelation when one of the Shards is closed

  #78 opened 6 years ago by emanuel-v-r
  3

• getShardIDs returns 100 shards at max

  #80 opened 6 years ago by lordfarhan40
  2

• ShardIteratorType - LATEST

  #74 opened 6 years ago by psolom
  4

• Please tag new release

  #71 opened 6 years ago by xzyfer
  1

• ddb checkpoint fails on initial call from scan if it was never written before.

  #70 opened 6 years ago by mguidone
  1

• Logging, new Logger interface

  #57 opened 6 years ago by emanuel-v-r
  9

• Usage of `withClient()`

  #45 opened 7 years ago by mikeholmesuk
  4

• support for more granular return values from the consumer callback function

  #43 opened 6 years ago by melugoyal
  1

• I've got syntax error: unexpected = in type declaration

  #41 opened 7 years ago by sinnawat
  2

• Add buffer to DDB Checkpoint

  #39 opened 7 years ago by harlow
  2