* Updating AWS SDK version to 2.10.56
* Changing default netty client to use 60 second ping health check timeout and 10MB initial window size.
* Tuning default request response timeout to 60 seconds.
* Revalidate if current shard is closed before shutting down the ShardConsumer
* KCL 2.2.5 release
* KCL 2.2.5 release
* Fixing bad merge
* Update the KINESIS_CLIENT_LIB_USER_AGENT_VERSION
* Revalidate if current shard is closed before shutting down the ShardConsumer
* Renaming Method
* Force Lease to be lost before shutting down with Zombi state
* Adding comments for ShardEnd related unit tests
* Making test cases resilient to delayed thread operations
* Setting the initial demand in test cases to be in line with service's coral initial demand.
* Fix to prevent the onNext event going to stale subscription when restart happens in poller
* Isolating session variables into a new class. Replacing thread control shifting logic for publishing with monitor based control
* Refactoring based on review comments
* Addressing review comments on unit test cases
* Preventing duplicate delivery due to unacknowledged event while completing the subscription
* Refactored clearRecordsDeliveryQueue logic and added comments
* Code refactoring as per review comments
* Nit fix
* Add logging to unexpected subscription state scenario
* Adding unit test case for record delivery validation
* Initial prototype for notification mechanism between ShardConsumerSubscriber and FanoutPublisher. The SDK Threads are made to block wait on the ack from the ShardConsumerSubscriber
* initial non blocking prototype
* Refactoring src and test
* Added unit test cases. Addressed review comments. Handled edge cases
* Minor code changes. Note that the previous commit has blocking impl of PrefetchPublisher
* Refactored the cleanup logic
* Fix for Cloudwatch exception handling and other revioew comment fixes
* Typo fix
* Removing cloudwatch fix. Will be released in a separate commit.
* Changing RejectedTaskEvent log message for the release
* Added javadoc to RecordsDeliveryAck and optimized imports
* Adding Kinesis Internal API tag for new concrete implementations
