diff --git a/CHANGELOG.md b/CHANGELOG.md index cecb3f240..861543708 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,26 @@ # Changelog +### Release 2.0.2 (September 4, 2018) +[Milestone #22](https://github.com/awslabs/amazon-kinesis-client/milestone/22) +* Fixed an issue where the a warning would be logged every second if `logWarningForTaskAfterMillis` was set. + The logging for last time of data arrival now respects the value of `logWarningForTaskAfterMillis`. + * [PR #383](https://github.com/awslabs/amazon-kinesis-client/pull/383) + * [Issue #381](https://github.com/awslabs/amazon-kinesis-client/issues/381) +* Moved creation of `WorkerStateChangedListener` and `GracefulShutdownCoordinator` to the `CoordinatorConfig`. + Originally the `WorkerStateChangedListener` and `GracefulShutdownCoordinator` were created by methods on the `SchedulerCoordinatorFactory`, but they should have been configuration options. + The original methods have been deprecated, and may be removed at a later date. + * [PR #385](https://github.com/awslabs/amazon-kinesis-client/pull/385) + * [PR #388](https://github.com/awslabs/amazon-kinesis-client/pull/388) +* Removed dependency on Apache Commons Lang 2.6. + The dependency on Apache Commons Lang 2.6 has removed, and all usages updated to use Apache Commons Lang 3.7. + * [PR #386](https://github.com/awslabs/amazon-kinesis-client/pull/386) + * [Issue #370](https://github.com/awslabs/amazon-kinesis-client/issues/370) +* Fixed a typo in the MutliLang Daemon shutdown hook. + * [PR #387](https://github.com/awslabs/amazon-kinesis-client/pull/387) +* Added method `onAllInitializationAttemptsFailed(Throwable)` to `WorkerStateChangedListener` to report when all initialization attempts have failed. + This method is a default method, and it isn't require to implement the method. This method is only called after all attempts to initialize the `Scheduler` have failed. + * [PR #369](https://github.com/awslabs/amazon-kinesis-client/pull/369) + ### Release 2.0.1 (August 21, 2018) * Mark certain internal components with `@KinesisClientInternalApi` attribute. Components marked as internal may be deprecated at a faster rate than public components. diff --git a/README.md b/README.md index c32a1dcb2..ca2f5917b 100644 --- a/README.md +++ b/README.md @@ -41,45 +41,38 @@ The recommended way to use the KCL for Java is to consume it from Maven. ``` ### Version 1.x +[Version 1.x tracking branch](https://github.com/awslabs/amazon-kinesis-client/tree/v1.x) ``` xml com.amazonaws amazon-kinesis-client - 1.9.1 + 1.9.2 ``` ## Release Notes -### Latest Release (2.0.1) -* Mark certain internal components with `@KinesisClientInternalApi` attribute. - Components marked as internal may be deprecated at a faster rate than public components. - * [PR #358](https://github.com/awslabs/amazon-kinesis-client/pull/358) -* Fixed an issue where `ResourceNotFoundException` on subscription to a shard was not triggering end of shard handling. - If a lease table contains a shard that is no longer present in the stream attempt to subscribe to that shard will trigger a `ResourceNotFoundException`. These exception are treated the same as reaching the end of a shard. - * [PR #359](https://github.com/awslabs/amazon-kinesis-client/pull/359) -* Fixed an issue where the KCL would not Use the configured DynamoDB IOPs when creating the lease table. - * [PR #360](https://github.com/awslabs/amazon-kinesis-client/pull/360) -* Make the maximum number of Scheduler initialization attempts configurable. - The maximum number of `Scheduler` initialization attempts can be configured via `CoordinatorConfig#maxInitializationAttempts`. - * [PR #363](https://github.com/awslabs/amazon-kinesis-client/pull/363) - * [PR #368](https://github.com/awslabs/amazon-kinesis-client/pull/368) -* Fixed an issue where it was possible to get a duplicate record when resubscribing to a shard. - Subscribe to shard requires periodic resubscribing, and uses a new concept of a continuation sequence number. If the continuation sequence number was equal to the last record that record would be processed a second time. Resubscribing now uses `AFTER_SEQUENCE_NUMBER` to ensure that only later records are returned. - * [PR #371](https://github.com/awslabs/amazon-kinesis-client/pull/371) -* Upgraded to AWS SDK 2.0.1 - * [PR #372](https://github.com/awslabs/amazon-kinesis-client/pull/372) -* Fixed an issue where time based restart of the subscription wasn't resetting the `lastRequestTime`. - If a subscription hasn't delivered any data for more than 30 seconds it will be canceled and restarted. This detection is based of the `lastRequestTime` which wasn't getting reset after the restart was triggered. - * [PR #373](https://github.com/awslabs/amazon-kinesis-client/pull/373) -* Fixed an issue where requesting on the subscription from the `FanOutRecordsPublisher` could trigger an unexpected failure. - Due to a race condition the underlying flow in the subscription could be set to something else. The method is now synchronized, and verifies that the subscriber it was created with is still the subscriber in affect. - This issue generally would only appear when multiple errors were occurring while connecting to Kinesis. - * [PR #374](https://github.com/awslabs/amazon-kinesis-client/pull/374) -* Fixed an issue where the number of requested items could exceed the capacity of the RxJava queue. - There was an off by one issue when determining whether to make a request to the SDK subscription. This changes the calculation to represent the capacity as a queue. - * [PR #375](https://github.com/awslabs/amazon-kinesis-client/pull/375) +### Latest Release (2.0.2 - September 4, 2018) +[Milestone #22](https://github.com/awslabs/amazon-kinesis-client/milestone/22) +* Fixed an issue where the a warning would be logged every second if `logWarningForTaskAfterMillis` was set. + The logging for last time of data arrival now respects the value of `logWarningForTaskAfterMillis`. + * [PR #383](https://github.com/awslabs/amazon-kinesis-client/pull/383) + * [Issue #381](https://github.com/awslabs/amazon-kinesis-client/issues/381) +* Moved creation of `WorkerStateChangedListener` and `GracefulShutdownCoordinator` to the `CoordinatorConfig`. + Originally the `WorkerStateChangedListener` and `GracefulShutdownCoordinator` were created by methods on the `SchedulerCoordinatorFactory`, but they should have been configuration options. + The original methods have been deprecated, and may be removed at a later date. + * [PR #385](https://github.com/awslabs/amazon-kinesis-client/pull/385) + * [PR #388](https://github.com/awslabs/amazon-kinesis-client/pull/388) +* Removed dependency on Apache Commons Lang 2.6. + The dependency on Apache Commons Lang 2.6 has removed, and all usages updated to use Apache Commons Lang 3.7. + * [PR #386](https://github.com/awslabs/amazon-kinesis-client/pull/386) + * [Issue #370](https://github.com/awslabs/amazon-kinesis-client/issues/370) +* Fixed a typo in the MutliLang Daemon shutdown hook. + * [PR #387](https://github.com/awslabs/amazon-kinesis-client/pull/387) +* Added method `onAllInitializationAttemptsFailed(Throwable)` to `WorkerStateChangedListener` to report when all initialization attempts have failed. + This method is a default method, and it isn't require to implement the method. This method is only called after all attempts to initialize the `Scheduler` have failed. + * [PR #369](https://github.com/awslabs/amazon-kinesis-client/pull/369) ### For remaining release notes check **[CHANGELOG.md][changelog-md]**. diff --git a/amazon-kinesis-client-multilang/pom.xml b/amazon-kinesis-client-multilang/pom.xml index a05ed42aa..02b72fa68 100644 --- a/amazon-kinesis-client-multilang/pom.xml +++ b/amazon-kinesis-client-multilang/pom.xml @@ -19,7 +19,7 @@ amazon-kinesis-client-pom software.amazon.kinesis - 2.0.2-SNAPSHOT + 2.0.2 4.0.0 diff --git a/amazon-kinesis-client/pom.xml b/amazon-kinesis-client/pom.xml index 51473ae94..5bfd0a951 100644 --- a/amazon-kinesis-client/pom.xml +++ b/amazon-kinesis-client/pom.xml @@ -20,7 +20,7 @@ software.amazon.kinesis amazon-kinesis-client-pom - 2.0.2-SNAPSHOT + 2.0.2 amazon-kinesis-client diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RetrievalConfig.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RetrievalConfig.java index 3252afc30..94252e47b 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RetrievalConfig.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RetrievalConfig.java @@ -34,7 +34,7 @@ public class RetrievalConfig { */ public static final String KINESIS_CLIENT_LIB_USER_AGENT = "amazon-kinesis-client-library-java"; - public static final String KINESIS_CLIENT_LIB_USER_AGENT_VERSION = "2.0.1"; + public static final String KINESIS_CLIENT_LIB_USER_AGENT_VERSION = "2.0.2"; /** * Client used to make calls to Kinesis for records retrieval diff --git a/pom.xml b/pom.xml index ec41160e6..21bcc345b 100644 --- a/pom.xml +++ b/pom.xml @@ -20,7 +20,7 @@ amazon-kinesis-client-pom pom Amazon Kinesis Client Library - 2.0.2-SNAPSHOT + 2.0.2 The Amazon Kinesis Client Library for Java enables Java developers to easily consume and process data from Amazon Kinesis. @@ -58,6 +58,17 @@ + + + ossrh + https://oss.sonatype.org/content/repositories/snapshots + + + ossrh + https://oss.sonatype.org/service/local/staging/deploy/maven2/ + + +