vendredi 24 avril 2015

Kinesis: What is the best/safe way to shutdown a worker?

I am using the AWS Kinesis Client Library.

I need a way to shutdown Kinesis Worker thread during deployments so that I stop at a checkpoint and not in the middle of processRecords().

I see a shutdown boolean present in Worker.java but its made private




Aucun commentaire:

Enregistrer un commentaire