1.3.0

Changes between 1.2.0 and 1.3.0

This is a minor release with new features, bug fixes, dependency upgrades, and some internal refactoring. It is compatible with 1.2.0. All users are encouraged to upgrade.

Refresh candidate nodes in recovery in case of connection reset

GitHub PR: #847

Stop reconnecting locator is environment is closed

GitHub PR: #846

Add flow strategy to credit every n chunks

GitHub PR: #843

Fix tracking check

GitHub PR: #837

Add resource listeners to track producer/consumer state

GitHub PR: #836

Fail RPC requests in case of asynchronous failure

GitHub PR: #814

Fix race condition on connection closing

GitHub PR: #813

Clean up outstanding requests on error and on closing

GitHub PR: #812

Support OAuth2 authentication

GitHub PR: #809

Bump dependencies

GitHub issue: #799

Dependency

Maven

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>stream-client</artifactId>
  <version>1.3.0</version>
</dependency>

Gradle

compile "com.rabbitmq:stream-client:1.3.0"

1.2.0

Changes between 1.1.0 and 1.2.0

This is a minor release with a new feature, a bug fix, dependency upgrades, and some internal refactoring. It is compatible with 1.1.0. All users are encouraged to upgrade.

Add Environment#storeOffset(String,String,long)

GitHub PR: #779

Close resources if environment initialization fails

GitHub PR: #783

Bump dependencies

GitHub issue: #767

Use Netty 4.2 adaptative byte buffer allocator by default

GitHub PR: #793

Consider max unconfirmed messages in dynamic batch configuration

GitHub PR: #773

Dependency

Maven

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>stream-client</artifactId>
  <version>1.2.0</version>
</dependency>

Gradle

compile "com.rabbitmq:stream-client:1.2.0"

1.1.0

Changes between 1.0.0 and 1.1.0

This is a minor release with a bug fix and dependency upgrades. It is compatible with 1.0.0. All users are encouraged to upgrade.

Make dynamic batch pump more aggressively

GitHub PR: #757

Bump dependencies

GitHub issue: #748

Dependency

Maven

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>stream-client</artifactId>
  <version>1.1.0</version>
</dependency>

Gradle

compile "com.rabbitmq:stream-client:1.1.0"

1.0.0

Changes between 0.24.0 and 1.0.0

This is the first major release of the library. It includes usability changes and dependency upgrades. It is compatible with 0.24.0. All users are encouraged to upgrade. The library is considered production-ready and its API stable.

Note the library now requires at least Java 11.

Remove deprecated TlsConfiguration#hostnameVerification methods

GitHub PR: #747

Bump dependencies

GitHub issue: #741

Dependency

Maven

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>stream-client</artifactId>
  <version>1.0.0</version>
</dependency>

Gradle

compile "com.rabbitmq:stream-client:1.0.0"

0.24.0

Changes between 0.23.0 and 0.24.0

This is a minor release with usability changes and dependency upgrades. It is compatible with 0.23.0. All users are encouraged to upgrade. This is the last release of the 0.x line before the 1.0.0 release.

Note the library now requires at least Java 11.

Deprecate TlsConfiguration#hostnameVerification methods

GitHub issue: #740

Remove random and least-leaders leader locator strategy

GitHub PR: #732

Bump dependencies

GitHub issue: #731

Bump Netty to 4.2.0

GitHub PR: #709

Dependency

Maven

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>stream-client</artifactId>
  <version>0.24.0</version>
</dependency>

Gradle

compile "com.rabbitmq:stream-client:0.24.0"

0.23.0

Changes between 0.22.0 and 0.23.0

This is a minor release with a bug fix, a usability improvement, and dependency upgrades. It is compatible with 0.22.0. All users are encouraged to upgrade.

Note the library now requires at least Java 11.

Support map, list, and array types when decoding message annotations

GitHub issue: #728

Collect consumed metric message by message

GitHub PR: #700

Bump dependencies

GitHub issue: #696

Dependency

Maven

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>stream-client</artifactId>
  <version>0.23.0</version>
</dependency>

Gradle

compile "com.rabbitmq:stream-client:0.23.0"

0.22.0

Changes between 0.21.0 and 0.22.0

This is a minor release with a bug fix, reliability improvements, and dependency upgrades. All users are encouraged to upgrade.

Note the library now requires at least Java 11.

Retry stored offset lookup in consumer update callback

GitHub issue: #691

Use lock in executor service factory

GitHub issue: #690

Fix correlation ID increment

GitHub issue: #689

Bump dependencies

GitHub issue: #674

Dependency

Maven

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>stream-client</artifactId>
  <version>0.22.0</version>
</dependency>

Gradle

compile "com.rabbitmq:stream-client:0.22.0"

v0.21.0

Changes between 0.20.0 and 0.21.0

This is a minor release with a new feature, usability improvements, and dependency upgrades. All users are encouraged to upgrade.

Note the library now requires at least Java 11.

Use dynamic batch publishing by default

GitHub PR: #671

Add locator connection count setting

GitHub issue: #666

Add log messages to recovery test

GitHub PR: #665

Require at least Java 11

GitHub PR: #663

Add option to connect to a replica for producers

GitHub PR: #662

Connect to any stream member for consumers when using a load balancer

GitHub PR: #660

Bump dependencies

GitHub issue: #659

Dependency

Maven

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>stream-client</artifactId>
  <version>0.21.0</version>
</dependency>

Gradle

compile "com.rabbitmq:stream-client:0.21.0"

v0.20.0

Changes between 0.19.0 and 0.20.0

This is a minor release with a new experimental feature and dependency upgrades. It is compatible with 0.19.0. All users are encouraged to upgrade.

Add dynamic-batch publishing option (experimental)

GitHub PR: #649

Bump dependencies

GitHub issue: #645

Dependency

Maven

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>stream-client</artifactId>
  <version>0.20.0</version>
</dependency>

Gradle

compile "com.rabbitmq:stream-client:0.20.0"

0.19.0

Changes between 0.18.0 and 0.19.0

This is a minor release with new features, a bug fix, and dependency upgrades. It is compatible with 0.18.0. All users are encouraged to upgrade.

Add flag to opt-out republishing unconfirmed messages on producer recovery

GitHub PR: #642

Support arbitrary key-value argument in stream creator

GitHub PR: #637

Add initial member count to stream creator

GitHub PR: #635

Recover producers and consumers after timeout

GitHub issue: #630

Bump dependencies

GitHub issue: #636

Dependency

Maven

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>stream-client</artifactId>
  <version>0.19.0</version>
</dependency>

Gradle

compile "com.rabbitmq:stream-client:0.19.0"