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