Shutdown Not Called on Record Processors when Java KCL is Terminated

awslabs / amazon-kinesis-client

Client library for Amazon Kinesis

Apache License 2.0

644 stars 467 forks source link

Shutdown Not Called on Record Processors when Java KCL is Terminated #915

Open mitaligit opened 2 years ago

mitaligit commented 2 years ago

In Java KCL application, upon terminating the process (Ctrl+C or SIGTERM) it exits and doesn't call shutdownRequested method. Is shutdownRequested called upon receiving SIGTERM signal in java KCL? I found this issue https://github.com/awslabs/amazon-kinesis-client/issues/35 but looks like it was for MultiLangDaemon and not Java. Could you confirm if shutdownRequested method will be called in Java KCL as well?

frjonsen commented 1 year ago

It's a year later and I'm seeing the same issue. I call startGracefulShutdown with a timeout of three minutes. The future returns almost immediately with a false result. shutdownRequested in my record processor never gets called.

AvenciMag commented 1 year ago

I'm experiencing this issue as well. Would love to see if this has been fixed or if i'm just doing something wrong.

gabrielfmagalhaes commented 6 months ago

It seems that this issue was finally solved https://github.com/awslabs/amazon-kinesis-client/pull/1302