amazon-kinesis-client
amazon-kinesis-client copied to clipboard
Shutdown Not Called on Record Processors when Java KCL is Terminated
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?
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.
I'm experiencing this issue as well. Would love to see if this has been fixed or if i'm just doing something wrong.
It seems that this issue was finally solved https://github.com/awslabs/amazon-kinesis-client/pull/1302