d379aa87b9
build(deps-dev): bump junit.jupiter.version
...
Bumps `junit.jupiter.version` from 5.10.1 to 5.10.2.
Updates `org.junit.jupiter:junit-jupiter-engine` from 5.10.1 to 5.10.2
- [Release notes](https://github.com/junit-team/junit5/releases )
- [Commits](https://github.com/junit-team/junit5/compare/r5.10.1...r5.10.2 )
Updates `org.junit.jupiter:junit-jupiter-params` from 5.10.1 to 5.10.2
- [Release notes](https://github.com/junit-team/junit5/releases )
- [Commits](https://github.com/junit-team/junit5/compare/r5.10.1...r5.10.2 )
---
updated-dependencies:
- dependency-name: org.junit.jupiter:junit-jupiter-engine
dependency-type: direct:development
update-type: version-update:semver-patch
- dependency-name: org.junit.jupiter:junit-jupiter-params
dependency-type: direct:development
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2024-02-05 18:08:21 +00:00
9593b77e82
build(deps-dev): bump org.assertj:assertj-core
...
Bumps [org.assertj:assertj-core](https://github.com/assertj/assertj ) from 3.25.2 to 3.25.3.
- [Release notes](https://github.com/assertj/assertj/releases )
- [Commits](https://github.com/assertj/assertj/compare/assertj-build-3.25.2...assertj-build-3.25.3 )
---
updated-dependencies:
- dependency-name: org.assertj:assertj-core
dependency-type: direct:development
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2024-02-05 18:06:09 +00:00
9c79ad8d55
More missed license header updates #9969
2024-02-05 12:26:25 -05:00
f414c2d512
More missed license header updates #9969
2024-02-05 11:53:50 -05:00
b1d7037c7d
Merge pull request #10331 from rabbitmq/stream-coordinator-fixes
...
Stream coordinator: fixes to automatic membership changes.
2024-01-26 15:39:27 +00:00
f617244806
build(deps-dev): bump org.assertj:assertj-core
...
Bumps [org.assertj:assertj-core](https://github.com/assertj/assertj ) from 3.25.1 to 3.25.2.
- [Release notes](https://github.com/assertj/assertj/releases )
- [Commits](https://github.com/assertj/assertj/compare/assertj-build-3.25.1...assertj-build-3.25.2 )
---
updated-dependencies:
- dependency-name: org.assertj:assertj-core
dependency-type: direct:development
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2024-01-24 18:37:56 +00:00
45e5cb1dba
rabbit_streams_SUITE test fix
2024-01-24 15:12:44 +00:00
61ac44d9ab
build(deps): bump com.diffplug.spotless:spotless-maven-plugin
...
Bumps [com.diffplug.spotless:spotless-maven-plugin](https://github.com/diffplug/spotless ) from 2.42.0 to 2.43.0.
- [Changelog](https://github.com/diffplug/spotless/blob/main/CHANGES.md )
- [Commits](https://github.com/diffplug/spotless/compare/lib/2.42.0...lib/2.43.0 )
---
updated-dependencies:
- dependency-name: com.diffplug.spotless:spotless-maven-plugin
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
2024-01-23 18:50:10 +00:00
7b151a7651
More missed (c) header updates
2024-01-22 23:44:47 -05:00
ed3aecefd0
Use read permission for store_offset
...
Instead of write permission. Storing an offset in a stream
is not like adding messages to the stream, so we consider
the write permission to be too hard for this case.
Read permission, like for consuming, is more appropriate.
The implementation checks there is a subscription for
the target stream and falls back to an actual read
permission call if there is not (e.g. when the subscription
state goes away before store_offset is sent when closing a consumer).
Fixes #10383
2024-01-22 17:25:40 +01:00
bc2a11d1bd
Re-evaluate stream permissions after secret update
...
Re-evaluate permissions, cancel publishers and
subscriptions, send metadata update accordingly.
Move record definitions from the stream reader
to a dedicated header file to be able to write
unit tests.
Fixes #10292
2024-01-19 14:46:57 +01:00
2a94ea06f4
build(deps): bump com.diffplug.spotless:spotless-maven-plugin
...
Bumps [com.diffplug.spotless:spotless-maven-plugin](https://github.com/diffplug/spotless ) from 2.41.1 to 2.42.0.
- [Changelog](https://github.com/diffplug/spotless/blob/main/CHANGES.md )
- [Commits](https://github.com/diffplug/spotless/compare/maven/2.41.1...lib/2.42.0 )
---
updated-dependencies:
- dependency-name: com.diffplug.spotless:spotless-maven-plugin
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
2024-01-15 18:05:48 +00:00
bf79c54bce
build(deps): bump org.apache.maven.plugins:maven-surefire-plugin
...
Bumps [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire ) from 3.2.3 to 3.2.5.
- [Release notes](https://github.com/apache/maven-surefire/releases )
- [Commits](https://github.com/apache/maven-surefire/compare/surefire-3.2.3...surefire-3.2.5 )
---
updated-dependencies:
- dependency-name: org.apache.maven.plugins:maven-surefire-plugin
dependency-type: direct:production
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2024-01-10 18:58:00 +00:00
92fa8f34f3
build(deps-dev): bump org.assertj:assertj-core
...
Bumps [org.assertj:assertj-core](https://github.com/assertj/assertj ) from 3.25.0 to 3.25.1.
- [Release notes](https://github.com/assertj/assertj/releases )
- [Commits](https://github.com/assertj/assertj/compare/assertj-build-3.25.0...assertj-build-3.25.1 )
---
updated-dependencies:
- dependency-name: org.assertj:assertj-core
dependency-type: direct:development
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2024-01-03 18:14:32 +00:00
01092ff31f
(c) year bumps
2024-01-01 22:02:20 -05:00
f14b2d3755
build(deps-dev): bump org.assertj:assertj-core
...
Bumps [org.assertj:assertj-core](https://github.com/assertj/assertj ) from 3.24.2 to 3.25.0.
- [Release notes](https://github.com/assertj/assertj/releases )
- [Commits](https://github.com/assertj/assertj/compare/assertj-build-3.24.2...assertj-build-3.25.0 )
---
updated-dependencies:
- dependency-name: org.assertj:assertj-core
dependency-type: direct:development
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
2024-01-01 18:42:24 +00:00
ce8532c280
build(deps): bump org.apache.maven.plugins:maven-compiler-plugin
...
Bumps [org.apache.maven.plugins:maven-compiler-plugin](https://github.com/apache/maven-compiler-plugin ) from 3.12.0 to 3.12.1.
- [Release notes](https://github.com/apache/maven-compiler-plugin/releases )
- [Commits](https://github.com/apache/maven-compiler-plugin/compare/maven-compiler-plugin-3.12.0...maven-compiler-plugin-3.12.1 )
---
updated-dependencies:
- dependency-name: org.apache.maven.plugins:maven-compiler-plugin
dependency-type: direct:production
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-12-25 18:22:44 +00:00
32700b8d41
build(deps): bump org.apache.maven.plugins:maven-compiler-plugin
...
Bumps [org.apache.maven.plugins:maven-compiler-plugin](https://github.com/apache/maven-compiler-plugin ) from 3.11.0 to 3.12.0.
- [Release notes](https://github.com/apache/maven-compiler-plugin/releases )
- [Commits](https://github.com/apache/maven-compiler-plugin/compare/maven-compiler-plugin-3.11.0...maven-compiler-plugin-3.12.0 )
---
updated-dependencies:
- dependency-name: org.apache.maven.plugins:maven-compiler-plugin
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-12-19 18:59:55 +00:00
514f10eb43
build(deps): bump org.apache.maven.plugins:maven-surefire-plugin
...
Bumps [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire ) from 3.2.2 to 3.2.3.
- [Release notes](https://github.com/apache/maven-surefire/releases )
- [Commits](https://github.com/apache/maven-surefire/compare/surefire-3.2.2...surefire-3.2.3 )
---
updated-dependencies:
- dependency-name: org.apache.maven.plugins:maven-surefire-plugin
dependency-type: direct:production
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-12-13 18:38:46 +00:00
e660364e07
Merge pull request #10054 from rabbitmq/dependabot/maven/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/main/com.diffplug.spotless-spotless-maven-plugin-2.41.1
...
Bump com.diffplug.spotless:spotless-maven-plugin from 2.37.0 to 2.41.1 in /deps/rabbitmq_stream/test/rabbit_stream_SUITE_data
2023-12-05 16:40:42 -05:00
9e21f1f297
Bump com.diffplug.spotless:spotless-maven-plugin
...
Bumps [com.diffplug.spotless:spotless-maven-plugin](https://github.com/diffplug/spotless ) from 2.37.0 to 2.41.1.
- [Changelog](https://github.com/diffplug/spotless/blob/main/CHANGES.md )
- [Commits](https://github.com/diffplug/spotless/compare/lib/2.37.0...maven/2.41.1 )
---
updated-dependencies:
- dependency-name: com.diffplug.spotless:spotless-maven-plugin
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-12-05 18:09:22 +00:00
2833384de3
Bump junit.jupiter.version
...
Bumps `junit.jupiter.version` from 5.9.3 to 5.10.1.
Updates `org.junit.jupiter:junit-jupiter-engine` from 5.9.3 to 5.10.1
- [Release notes](https://github.com/junit-team/junit5/releases )
- [Commits](https://github.com/junit-team/junit5/compare/r5.9.3...r5.10.1 )
Updates `org.junit.jupiter:junit-jupiter-params` from 5.9.3 to 5.10.1
- [Release notes](https://github.com/junit-team/junit5/releases )
- [Commits](https://github.com/junit-team/junit5/compare/r5.9.3...r5.10.1 )
---
updated-dependencies:
- dependency-name: org.junit.jupiter:junit-jupiter-engine
dependency-type: direct:development
update-type: version-update:semver-minor
- dependency-name: org.junit.jupiter:junit-jupiter-params
dependency-type: direct:development
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-12-05 18:09:17 +00:00
af4aa3ef5c
Bump ch.qos.logback:logback-classic
...
Bumps [ch.qos.logback:logback-classic](https://github.com/qos-ch/logback ) from 1.2.12 to 1.2.13.
- [Commits](https://github.com/qos-ch/logback/compare/v_1.2.12...v_1.2.13 )
---
updated-dependencies:
- dependency-name: ch.qos.logback:logback-classic
dependency-type: direct:development
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-12-01 18:49:04 +00:00
1b642353ca
Update (c) according to [1]
...
1. https://investors.broadcom.com/news-releases/news-release-details/broadcom-and-vmware-intend-close-transaction-november-22-2023
2023-11-21 23:18:22 -05:00
f118d2fdce
Small refactor of stream tests
2023-11-17 10:49:12 +01:00
329988c483
Remove syntax test
2023-11-17 09:00:08 +01:00
0e5d15592a
Check virtual host queue limit on stream creation
...
Fixes #9910
2023-11-17 08:45:42 +01:00
739928153e
Add --binding-keys to add_super_stream command
...
It is meant to replace --routing-keys, which
is still available but not documented anymore.
This is to be consistent with AMQP 0.9.1 terminology.
2023-11-15 14:00:07 +01:00
2eb9b5f87b
Make sure partitions and binding keys counts are equal
2023-11-13 15:48:23 +01:00
9beda5702e
Use "binding key" lingo for super stream creation
...
Instead of "routing key".
2023-11-13 14:54:45 +01:00
043ddcba95
Add super stream creation/deletion test
2023-11-13 10:30:25 +01:00
388608143d
Add super stream add/delete protocol commands
2023-11-13 10:30:25 +01:00
c3676c6c79
Bump org.apache.maven.plugins:maven-surefire-plugin
...
Bumps [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire ) from 3.2.1 to 3.2.2.
- [Release notes](https://github.com/apache/maven-surefire/releases )
- [Commits](https://github.com/apache/maven-surefire/compare/surefire-3.2.1...surefire-3.2.2 )
---
updated-dependencies:
- dependency-name: org.apache.maven.plugins:maven-surefire-plugin
dependency-type: direct:production
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-11-07 18:30:48 +00:00
feaeea2f2e
Bump org.apache.maven.plugins:maven-surefire-plugin
...
Bumps [org.apache.maven.plugins:maven-surefire-plugin](https://github.com/apache/maven-surefire ) from 3.1.2 to 3.2.1.
- [Release notes](https://github.com/apache/maven-surefire/releases )
- [Commits](https://github.com/apache/maven-surefire/compare/surefire-3.1.2...surefire-3.2.1 )
---
updated-dependencies:
- dependency-name: org.apache.maven.plugins:maven-surefire-plugin
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-10-24 18:22:19 +00:00
55bd90c0e4
Merge pull request #9187 from rabbitmq/update-secret
...
Update secret on the stream protocol
2023-10-23 19:46:52 -04:00
c04d324b9f
Fix list_stream_consumer_groups validation
...
It had been broken in a refactoring to squash
dialyzer warnings.
2023-10-10 16:44:05 +02:00
b541be658e
Use tracking_value for column header
2023-10-10 09:14:24 +02:00
048a4998ed
Add list_stream_tracking
2023-10-10 09:14:23 +02:00
944b34e4e0
Add pid and node columns to list_stream_connections
...
Fixes #9555
2023-09-30 14:59:25 -04:00
db65caa91f
Add node column to list_stream_publishers/consumers
...
Fixes #9582
2023-09-30 14:59:25 -04:00
289fc51def
Monitor members to the same stream in stream connection
...
This commit change makes sure that different members
of the same stream are monitored in a given connection.
A connection can use the stream leader for a publisher
and a replica for a consumer, if the replica crashes
for some reason, the connection must detect it and
send a metadata notification to the client.
Note that client connections should still use different
connections for publishers and consumers.
2023-09-28 17:09:29 +02:00
b715a4d07c
Update secret via sasl_authentication frame
2023-08-25 11:32:24 +01:00
c594c77049
Adapt stream Java tests to client 0.12.0 snapshot
...
After changes for
https://github.com/rabbitmq/rabbitmq-stream-java-client/issues/333 .
2023-07-17 11:04:25 +02:00
6ed8b30780
Merge pull request #8848 from rabbitmq/dependabot/maven/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/main/com.diffplug.spotless-spotless-maven-plugin-2.37.0
...
Bump spotless-maven-plugin from 2.24.0 to 2.37.0 in /deps/rabbitmq_stream/test/rabbit_stream_SUITE_data
2023-07-13 17:25:10 +02:00
dfc2ee65d8
Bump spotless-maven-plugin
...
Bumps [spotless-maven-plugin](https://github.com/diffplug/spotless ) from 2.24.0 to 2.37.0.
- [Changelog](https://github.com/diffplug/spotless/blob/main/CHANGES.md )
- [Commits](https://github.com/diffplug/spotless/compare/lib/2.24.0...lib/2.37.0 )
---
updated-dependencies:
- dependency-name: com.diffplug.spotless:spotless-maven-plugin
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-07-13 15:17:08 +00:00
18d36662df
Bump junit.jupiter.version
...
Bumps `junit.jupiter.version` from 5.9.0 to 5.9.3.
Updates `junit-jupiter-engine` from 5.9.0 to 5.9.3
- [Release notes](https://github.com/junit-team/junit5/releases )
- [Commits](https://github.com/junit-team/junit5/compare/r5.9.0...r5.9.3 )
Updates `junit-jupiter-params` from 5.9.0 to 5.9.3
- [Release notes](https://github.com/junit-team/junit5/releases )
- [Commits](https://github.com/junit-team/junit5/compare/r5.9.0...r5.9.3 )
---
updated-dependencies:
- dependency-name: org.junit.jupiter:junit-jupiter-engine
dependency-type: direct:development
update-type: version-update:semver-patch
- dependency-name: org.junit.jupiter:junit-jupiter-params
dependency-type: direct:development
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-07-13 15:17:02 +00:00
742c8ed994
Use stream Java client 0.11.0 in test suites
...
Just temporarily. This removes the need to use
a snapshot repository, which makes dependabot fail.
There's also a stream Java client update with
internal breaking changes, so we'll come back
to the latest snapshot once the tests are updated.
2023-07-13 17:12:51 +02:00
7bc26154b5
Add stream filtering feature flag
2023-07-10 15:21:53 +02:00
065844a6d6
Support stream-filter-size-bytes in stream protocol
2023-07-10 15:21:53 +02:00
58dc8b9d40
Add test for stream filtering
2023-07-10 15:21:52 +02:00
62c83b0b9d
Use "filter."-shaped subscription properties
...
To set filter values in stream protocol.
2023-07-10 15:21:52 +02:00
6f3398a49a
Bump logback-classic
...
Bumps [logback-classic](https://github.com/qos-ch/logback ) from 1.2.11 to 1.2.12.
- [Commits](https://github.com/qos-ch/logback/compare/v_1.2.11...v_1.2.12 )
---
updated-dependencies:
- dependency-name: ch.qos.logback:logback-classic
dependency-type: direct:development
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-06-30 15:32:16 +00:00
14c43d6c30
Bump maven-compiler-plugin
...
Bumps [maven-compiler-plugin](https://github.com/apache/maven-compiler-plugin ) from 3.10.1 to 3.11.0.
- [Release notes](https://github.com/apache/maven-compiler-plugin/releases )
- [Commits](https://github.com/apache/maven-compiler-plugin/compare/maven-compiler-plugin-3.10.1...maven-compiler-plugin-3.11.0 )
---
updated-dependencies:
- dependency-name: org.apache.maven.plugins:maven-compiler-plugin
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-06-30 15:07:23 +00:00
b39088ab87
Merge pull request #8721 from rabbitmq/dependabot/maven/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/main/org.apache.maven.plugins-maven-surefire-plugin-3.1.2
...
Bump maven-surefire-plugin from 2.22.2 to 3.1.2 in /deps/rabbitmq_stream/test/rabbit_stream_SUITE_data
2023-06-30 17:06:24 +02:00
e568bb6f9a
Bump maven-surefire-plugin
...
Bumps [maven-surefire-plugin](https://github.com/apache/maven-surefire ) from 2.22.2 to 3.1.2.
- [Release notes](https://github.com/apache/maven-surefire/releases )
- [Commits](https://github.com/apache/maven-surefire/compare/surefire-2.22.2...surefire-3.1.2 )
---
updated-dependencies:
- dependency-name: org.apache.maven.plugins:maven-surefire-plugin
dependency-type: direct:production
update-type: version-update:semver-major
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-06-30 14:02:53 +00:00
2a19ba07c2
Bump assertj-core in /deps/rabbitmq_stream/test/rabbit_stream_SUITE_data
...
Bumps assertj-core from 3.23.1 to 3.24.2.
---
updated-dependencies:
- dependency-name: org.assertj:assertj-core
dependency-type: direct:development
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
2023-06-30 14:02:31 +00:00
1315f5c26c
Bump Google Java Format
2023-06-30 10:03:56 +02:00
55442aa914
Replace @rabbitmq.com addresses with rabbitmq-core@groups.vmware.com
...
Don't ask why we have to do it. Because reasons!
2023-06-20 15:40:13 +04:00
d04b3afe9b
verify_none in a couple of tests
2023-04-24 13:11:44 +00:00
dcc24fce1c
Set `{verify, verify_none}` in rabbit_stream_SUITE
2023-04-13 14:37:19 +02:00
763acc2fad
Introduce timeout for stream server-side requests
...
The stream plugin can send frames to a client connection
and expect a response from it. This is used currently
for the consumer_update frame (single active consumer feature).
There was no timeout mechanism so far, so a slow or blocked
application could prevent a group of consumers to move on.
This commit introduces a timeout mechanism: if the expected
response takes too long to arrive, the server assumes the
connection is blocked and closes it.
The default timeout is 60 seconds but it can be changed by setting
the request_timeout parameter of the rabbitmq_stream application.
Note the mechanism does not enforce the exact duration of the timeout,
as a timer is set for the first request and re-used for other requests.
With bad timing, a request can time out after twice as long
as the set-up timeout.
References #7743
2023-04-04 19:32:57 +04:00
4d7403cb62
Delete rabbit_stream_SUITE setup steps
...
since these feature flags became required in 3.12.
2023-02-15 17:01:59 +00:00
5045fce6de
Require all feature flags introduced before 3.11.1
...
RabbitMQ 3.12 requires feature flag `feature_flags_v2` which got
introduced in 3.11.0 (see
https://github.com/rabbitmq/rabbitmq-server/pull/6810 ).
Therefore, we can mark all feature flags that got introduced in 3.11.0
or before 3.11.0 as required because users will have to upgrade to
3.11.x first, before upgrading to 3.12.x
The advantage of marking these feature flags as required is that we can
start deleting any compatibliy code for these feature flags, similarly
as done in https://github.com/rabbitmq/rabbitmq-server/issues/5215
This list shows when a given feature flag was first introduced:
```
classic_mirrored_queue_version 3.11.0
stream_single_active_consumer 3.11.0
direct_exchange_routing_v2 3.11.0
listener_records_in_ets 3.11.0
tracking_records_in_ets 3.11.0
empty_basic_get_metric 3.8.10
drop_unroutable_metric 3.8.10
```
In this commit, we also force all required feature flags in Erlang
application `rabbit` to be enabled in mixed version cluster testing
and delete any tests that were about a feature flag starting as disabled.
Furthermore, this commit already deletes the callback (migration) functions
given they do not run anymore in 3.12.x.
All other clean up (i.e. branching depending on whether a feature flag
is enabled) will be done in separate commits.
2023-02-08 16:00:03 +00:00
3fea81a7ee
Remove console output
2023-01-04 15:56:49 +01:00
d2443b5f49
Filter out nodes in maintenance in stream metadata
...
We don't want clients to try to connect to those.
Fixes #3370
2023-01-04 15:54:20 +01:00
79990e8eae
Format stream plugin code
2023-01-04 10:47:16 +01:00
ec4f1dba7d
(c) year bump: 2022 => 2023
2023-01-01 23:17:36 -05:00
c1ab6b42d4
Use assertMatch instead of assertEqual in test
...
Make test less fragile.
2022-11-17 15:52:01 +01:00
e4921503db
Streams: close osiris log on unsubscribe
...
To ensure we clean up any log resources such as counter records.
2022-11-03 16:54:31 +00:00
7fe159edef
Yolo-replace format strings
...
Replaces `~s` and `~p` with their unicode-friendly counterparts.
```
git ls-files *.erl | xargs sed -i.ORIG -e s/~s>/~ts/g -e s/~p>/~tp/g
```
2022-10-10 10:32:03 +04:00
fa528115b1
Bump dependencies in stream Java test
2022-08-10 09:56:58 +02:00
68969faf94
Streams: adapt tests to the latest Java stream client listener interface
2022-08-10 11:43:44 +04:00
93c33f2423
Rename StreamInfo to StreamStats
...
Other changes: returns a map of int64, use the new osiris:get_stats/1 API.
References #5412
2022-08-08 18:02:51 +02:00
8687e73c7e
Add StreamInfo command to stream protocol
...
It returns general information on a stream, the first
and committed offsets for now.
Fixes #5412
2022-08-03 14:38:45 +02:00
6e9ee4d0da
Remove test code which depended on the `quorum_queue` feature flags
...
These checks are now irrelevant as the feature flag is required.
2022-08-01 12:41:30 +02:00
776b4323bd
Remove test code which depended on the `virtual_host_metadata` feature flags
...
These checks are now irrelevant as the feature flag is required.
2022-08-01 11:56:53 +02:00
32e118fada
Remove test code which depended on feature flag implicit_default_bindings
...
The feature flag is required.
References #5215 .
2022-07-29 15:03:26 +00:00
5b98d7d2a2
Remove test code which depended on the `maintenance_mode_status` feature flags
...
These checks are now irrelevant as the feature flag is required.
2022-07-29 11:51:52 +02:00
32049cd256
Remove test code which depended on the `user_limits` feature flags
...
These checks are now irrelevant as the feature flag is required.
2022-07-29 11:04:48 +02:00
95f3fdef19
Use "committed offset" instead of "last committed offset"
...
References #5307
2022-07-26 11:37:46 +02:00
9795727b9f
Include last committed offset in "deliver" stream command
...
Fixes #5307
2022-07-25 16:15:04 +02:00
67aac95f3e
Add exchange command versions command to stream plugin
...
References #5308
2022-07-25 16:15:03 +02:00
e44b65957d
Limit stream max segment size to 3 GB
...
Values too large can overflow the stream position field
in the index (32 bit int).
2022-06-10 11:45:57 +02:00
0806fa0b2f
Add stream single active consumer feature flag
...
Block stream SAC functions if the feature flag is not enabled.
References #3753
2022-05-09 10:52:32 +02:00
0623192130
Handle "active" field for stream consumers
...
In the regular metrics ETS table, not the one from streams.
References #3753
2022-05-09 10:52:31 +02:00
5ad9e349e0
Add list_stream_group_consumers CLI command
...
References #3753
2022-05-09 10:52:31 +02:00
434d7b5c54
Add colums argument to list_stream_consumer_groups
...
References #3753
2022-05-09 10:52:30 +02:00
1ec49a7aa3
Add list_stream_consumer_groups CLI command
...
References #3753
2022-05-09 10:52:29 +02:00
eeefd7c860
Monitor connection PIDs in stream SAC coordinator
...
References #3753
2022-05-09 10:52:27 +02:00
d98b10f78d
Compute stream partition index
...
References #3753
2022-05-09 10:52:21 +02:00
7c47d0925a
Revert "Correct a double quote introduced in #4603"
...
This reverts commit 6a44e0e2ef
2022-04-20 16:05:56 +04:00
6a44e0e2ef
Correct a double quote introduced in #4603
2022-04-20 16:01:29 +04:00
a9cc401e3c
Bump Java test suites dependencies for stream plugins
2022-04-01 16:42:32 +02:00
c38a3d697d
Bump (c) year
2022-03-21 01:21:56 +04:00
96c9270fb3
Bump dependencies in streams Java tests
2022-01-17 16:13:29 +01:00
1bcca0745e
Increase timeout in stream test
...
Some CI environment may need a bit more time.
2021-12-10 12:08:02 +01:00
4c397c54fa
Use AssertJ conditions in Java stream test suite
2021-12-10 11:52:54 +01:00
bd4771addb
Return appropriate response when stream leader not available
...
Fixes #3874
2021-12-10 10:58:48 +01:00
8f40e534ed
Bump Java test dependencies in stream test suites
2021-12-10 09:18:22 +01:00
17d0ba9317
Return "no offset" (19) code when stored offset is undefined
...
Fixes #3783
2021-12-01 17:59:14 +01:00
dependabot[bot]
Michael Klishin
Michael Klishin
Karl Nilsson
Arnaud Cogoluègnes
Marcial Rosales
Michal Kuratczyk
David Ansari
Luke Bakken
Jean-Sébastien Pédron