This is an automated email from the ASF dual-hosted git repository.
mmodzelewski pushed a change to branch java-vsr
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 0904cb783 feat(java): migrate the TCP client to the VSR wire protocol
add 60fa1a05b fixes
add 01a64b2e0 test(integration): fix vsr flakes from racing recovery
routes (#3833)
add d5c795339 Merge branch 'master' into java-vsr
No new revisions were added by this update.
Summary of changes:
.../tests/cluster/metadata_state_transfer.rs | 28 +-
.../tests/cluster/partition_state_transfer.rs | 67 ++++-
.../integration/tests/connectors/http/http_sink.rs | 65 +++--
core/integration/tests/data_integrity/mod.rs | 11 +-
.../verify_consumer_group_partition_assignment.rs | 18 +-
.../server/scenarios/message_cleanup_scenario.rs | 129 +++++---
core/integration/tests/server/scenarios/mod.rs | 2 -
.../scenarios/stress_produce_consume_scenario.rs | 264 -----------------
core/partitions/src/iggy_partition.rs | 13 +
core/server-ng/src/auth.rs | 6 +-
examples/java/README.md | 14 +-
foreign/java/README.md | 3 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 111 ++++++-
.../async/tcp/AsyncIggyTcpClientBuilder.java | 7 +
.../iggy/client/async/tcp/AsyncTcpConnection.java | 293 ++++++++++++++++---
.../iggy/client/async/tcp/IggyAuthenticator.java | 31 +-
.../client/async/tcp/vsr/VsrResponseHandler.java | 38 ++-
.../org/apache/iggy/exception/IggyErrorCode.java | 9 +-
.../iggy/exception/IggyValidationException.java | 1 +
.../org/apache/iggy/serde/BytesDeserializer.java | 21 +-
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 14 +
.../AsyncIggyTcpClientTransientFailoverTest.java | 323 +++++++++++++++++++++
.../tcp/AsyncTcpConnectionRequestTimeoutTest.java | 92 ++++++
.../async/tcp/vsr/VsrRequestEncoderTest.java | 2 +
.../async/tcp/vsr/VsrResponseHandlerTest.java | 24 ++
.../apache/iggy/exception/IggyErrorCodeTest.java | 9 +-
.../iggy/exception/IggyServerExceptionTest.java | 9 +
.../exception/IggyValidationExceptionTest.java | 2 +
.../apache/iggy/serde/BytesDeserializerTest.java | 21 ++
scripts/run-examples-from-readme.sh | 2 +-
30 files changed, 1167 insertions(+), 462 deletions(-)
delete mode 100644
core/integration/tests/server/scenarios/stress_produce_consume_scenario.rs
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/AsyncIggyTcpClientTransientFailoverTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/AsyncTcpConnectionRequestTimeoutTest.java
