daangn / kinesumer

A Go client implementing a client-side distributed consumer group client for Amazon Kinesis
Apache License 2.0
76 stars 6 forks source link

fix: duplicate subscribe to shard #19

Open proost opened 1 year ago

proost commented 1 year ago

If use Enhance Fan-out mode and subscribing interval is too short and consumer didn't changed, then get ResourceInUseException: Another active subscription exists for this consumer error. so try not to resubscribe too fast.

Also, close EventStream when EventStream is closed to prevent resource leak.