This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch improve_state_machine_apply
in repository https://gitbox.apache.org/repos/asf/iggy.git
from cfcc9a9cf Merge branch 'master' into improve_state_machine_apply
add 272810093 chore(repo): bump version of all packages for new release
(#2758)
add 78ef2b9ee docs(java): add async client JavaDoc and usage guide (#2711)
add 6d2c3b2a5 Merge branch 'master' into improve_state_machine_apply
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 38 +--
Cargo.toml | 8 +-
DEPENDENCIES.md | 38 +--
core/ai/mcp/Cargo.toml | 2 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/runtime/README.md | 6 +-
core/connectors/sdk/Cargo.toml | 2 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
core/sdk/Cargo.toml | 2 +-
core/server/Cargo.toml | 2 +-
examples/java/README.md | 95 +++++-
examples/java/build.gradle.kts | 5 +-
.../apache/iggy/examples/async/AsyncConsumer.java | 349 +++++++++++++++++++++
.../iggy/examples/async/AsyncConsumerExample.java | 157 ---------
.../apache/iggy/examples/async/AsyncProducer.java | 240 +++++++-------
examples/node/package-lock.json | 2 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
foreign/go/contracts/version.go | 2 +-
foreign/java/README.md | 9 +-
foreign/java/gradle.properties | 2 +-
.../iggy/client/async/ConsumerGroupsClient.java | 58 +++-
.../apache/iggy/client/async/MessagesClient.java | 126 ++++++--
.../apache/iggy/client/async/StreamsClient.java | 99 ++++++
.../org/apache/iggy/client/async/TopicsClient.java | 103 ++++--
.../org/apache/iggy/client/async/UsersClient.java | 48 ++-
.../org/apache/iggy/client/async/package-info.java | 57 ++++
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 112 ++++++-
.../apache/iggy/client/async/tcp/package-info.java | 48 +++
foreign/node/package-lock.json | 4 +-
foreign/node/package.json | 2 +-
foreign/python/Cargo.toml | 4 +-
foreign/python/pyproject.toml | 2 +-
helm/charts/iggy/Chart.yaml | 4 +-
helm/charts/iggy/values.yaml | 2 +-
scripts/extract-version.sh | 2 +-
web/package-lock.json | 4 +-
web/package.json | 2 +-
50 files changed, 1204 insertions(+), 464 deletions(-)
create mode 100644
examples/java/src/main/java/org/apache/iggy/examples/async/AsyncConsumer.java
delete mode 100644
examples/java/src/main/java/org/apache/iggy/examples/async/AsyncConsumerExample.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/package-info.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/package-info.java
