search

awslabs / amazon-kinesis-client

Client library for Amazon Kinesis
Apache License 2.0
643 stars 466 forks source link

KCL 1.14.3 - assigning shards to instances of consumer app - delay losing shard #831

Open mateusz1364 opened 3 years ago

mateusz1364 commented 3 years ago

I have a application , two shards and two instances of consumer app (KCL).

On the start , the first instance get both shards and starting processing data, after a few moments later the second app is starting and takes second shard, in first instance is invoked method to losing shard (separate thread). Log below:

[LeaseRenewer-0004] c.a.s.k.leases.impl.LeaseRenewer - Worker 7d2f89c1-fbb1-4480-9488-XXXXXXXXXX lost lease with key shardId-0000000000XX

My question, how to delay losing shard and finish gracefully processing data.

stirlingcarter commented 2 years ago

I'm facing the same issue haven't found a fix