Error when Spring Cloud Kinesis app is stopped

[jkatnik]

Hi

on app shutdown following exception is logged which creates false alarms in our monitoring system.
It would be great if this exception could be somehow suppressed.

org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter

ShardConsumerManager Thread [org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter$ShardConsumerManager@65d67f8a] has been interrupted

java.lang.InterruptedException: sleep interrupted 	at java.lang.Thread.sleep(Thread.java) 	at org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter.sleep(KinesisMessageDrivenChannelAdapter.java:650) 	at org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter.access$1400(KinesisMessageDrivenChannelAdapter.java:98) 	at org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter$ShardConsumerManager.run(KinesisMessageDrivenChannelAdapter.java:1391)

Problem is present in release 2.3.3, I haven't tested 2.3.4

For the reference: the same issue was reported on stackoverflow by some other developer and answered by @artembilan
https://stackoverflow.com/questions/64973589/error-when-spring-cloud-kinesis-app-is-stopped

Kind Regards
Jarek

[artembilan]

Treating as a bug.

Please, consider to contribute the fix.
Will review and merge shortly.

Thank you!

[jkatnik]

Hi @artembilan
PR ready for review
#189