v0.15.0

Changes between 0.14.0 and 0.15.0

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

Support super stream creation/deletion (RabbitMQ 3.13)

GitHub PR: #448

Allocate producer/consumer IDs with a sequence

GitHub PR: #478

Bump dependencies

GitHub issue: #447

Dependency

Maven

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

Gradle

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

0.14.0

Changes between 0.13.0 and 0.14.0

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

The performance tool has been moved to a standalone project. It is no longer distributed along the stream Java client.

Do not unsubscribe with closed client

GitHub PR: #437

Bump dependencies

GitHub issue: #435

Move performance tool to a standalone project

GitHub issue: #446

Dependency

Maven

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

Gradle

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

0.13.0

Changes between 0.12.0 and 0.13.0

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

Add options for connection and topology recovery to performance tool

GitHub issue: #427

Add --heartbeat option to performance tool

GitHub issue: #426

Use Java 21 in the performance tool Docker image

GitHub PR: #423

Force localhost for local development

GitHub PR: #420

Fix coordinator manager creation in load balancer mode

GitHub PR: #409

Bump dependencies

GitHub issue: #391

Dependency

Maven

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

Gradle

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

0.12.0

Changes between 0.11.0 and 0.12.0

This is a minor release with new features, dependency upgrades, and the removal of deprecated Netty-related configuration API. It is compatible with 0.11.0 (except for the removed API). All users are encouraged to upgrade.

Thanks to Henrique Campos (@henry701) for his contribution.

Add consumer flow control API

GitHub issue: #333

Support for stream filtering (feature preview for RabbitMQ 3.13)

GitHub PR: #343

Bump dependencies

GitHub issue: #375

Remove deprecated Netty-related settings

GitHub issue: #376

Dependency

Maven

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

Gradle

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

0.11.0

Changes between 0.10.0 and 0.11.0

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

Make subscription initial credits configurable

GitHub PR: #372

Add Environment#streamExists(String)

GitHub PR: #370

Environment.queryStreamStats not doing lazy initialization

GitHub issue: #368

Bump dependencies

GitHub issue: #347

Dependency

Maven

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

Gradle

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

0.10.0

Changes between 0.9.0 and 0.10.0

This is a minor release with new features, usability improvements, bug fixes, and dependency upgrades. It is compatible with 0.9.0. All users are encouraged to upgrade.

Dispatch messages in a dedicated thread

GitHub PR: #298

Support multi-instance synchronized start-up

GitHub issue: #282

Exchange command versions in connection

GitHub PR: #276

Avoid division by 0 when computing partition

GitHub issue: #271

Add --native-epoll option to performance tool

GitHub issue: #270

Add extension point to configure Netty's bootstrap

GitHub issue: #269

Speed up exit when --time is used

GitHub PR: #268

Add --requested-max-frame-size to performance tool

GitHub issue: #265

Add batch publishing delay option in performance tool

GitHub issue: #259

Bump dependencies

GitHub issue: #254

0.9.0

Changes between 0.8.0 and 0.9.0

This is a minor release with new features, usability improvements, bug fixes, and dependency upgrades. It is compatible with 0.8.0. All users are encouraged to upgrade.

Improve recovery

GitHub PR: #245

Add stream-environment debug REST endpoint

GitHub issue: #235

Fix connection naming race condition

GitHub issue: #234

Include all flags in performance tool auto-completion script

GitHub issue: #232

Use Micrometer for console metrics in performance tool

GitHub PR: #231

Allow 0 for --max-length-bytes option (no limit)

GitHub PR: #230

Add percentiles to chunk size metrics in performance tool

GitHub PR: #228

Add --metrics-command-line-arguments option

GitHub issue: #227

Add --metrics-tags option

GitHub issue: #225

Use Ubuntu 22.04 in performance tool Docker image

GitHub issue: #221

Install Ubuntu updates when building the performance tool image

GitHub issue: #220

Handle null value in AMQP 1.0 codecs

GitHub issue: #206

Retry offset retrieval in case connection to leader is down

GitHub issue: #204

Reset subscription client on metadata update

GitHub issue: #203

Bump dependencies

GitHub issue: #200

0.8.0

Changes between 0.7.0 and 0.8.0

This is a minor release with a new feature in the performance tool, bug fixes, and dependency upgrades. It is compatible with 0.7.0. All users are encouraged to upgrade.

The library contains support for single active consumer and super streams since 0.7.0. These features are available in RabbitMQ 3.11 and can already be tested on 3.11.0-rc.2.

Add --time option to performance tool

GitHub issue: #198

Fix partition calculation in hash routing strategy

GitHub issue: #199

Super stream producer still works after being closed

GitHub issue: #193

Bump dependencies

GitHub issue: #181

0.7.0

Changes between 0.6.0 and 0.7.0

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

This release also contains support for single active consumer and super streams. These features are available in RabbitMQ 3.11 and can already be tested on 3.11.0-rc.1.

Make explicit that an instance has been closed

GitHub issue: #169

Bump dependencies

GitHub issue: #166

Support StreamInfo command

GitHub PR: #165

Include committed offset to message handler callback

GitHub issue: #158

Add support for single active consumer

GitHub issue: #46

0.6.0

Changes between 0.5.0 and 0.6.0

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

Use Java HttpServer to expose metrics and monitoring

GitHub issue: #152

Handle offset 0 in tracking

GitHub issue: #146

Stop dispatching when Consumer#close() is called

GitHub issue: #142

Limit segment size to 3 GB

GitHub issue: #132

Add publish confirm latency metrics to performance tool

GitHub issue: #129

Document address resolver hook

GitHub issue: #124

Add Id property to environment

GitHub issue: #113

Use client-local for default leader locator strategy

GitHub issue: #110

Document compression support

GitHub issue: #90

Add --rpc-timeout argument to performance tool

GitHub issue: #88

Clean state after subscription failure

GitHub issue: #87

Bump dependencies

GitHub issue: #85