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 c1d56fa11 refactor(metadata): improve the stm update method
add 8594d7d4c fix(security): harden all deserializers against malformed
packets (#2741)
add 11073ca80 fix(sdk): add leader redirection logic for
`login_with_personal_access_token` (#2752)
add 92ed133b0 refactor(java): extract base integration test class (#2749)
add 9ff670b5f ci(java): detect Netty ByteBuf memory leaks in CI tests
(#2755)
add cfcc9a9cf Merge branch 'master' into improve_state_machine_apply
No new revisions were added by this update.
Summary of changes:
.github/actions/java-gradle/pre-merge/action.yml | 10 ++
.../consumer_groups/create_consumer_group.rs | 30 +++-
.../consumer_offsets/delete_consumer_offset.rs | 10 +-
.../consumer_offsets/get_consumer_offset.rs | 10 +-
.../consumer_offsets/store_consumer_offset.rs | 14 +-
.../src/commands/messages/flush_unsaved_buffer.rs | 6 +-
core/common/src/commands/messages/poll_messages.rs | 24 ++-
.../src/commands/partitions/create_partitions.rs | 4 +-
.../src/commands/partitions/delete_partitions.rs | 4 +-
.../create_personal_access_token.rs | 23 +--
.../delete_personal_access_token.rs | 41 ++++-
.../login_with_personal_access_token.rs | 41 ++++-
.../src/commands/segments/delete_segments.rs | 8 +-
core/common/src/commands/streams/create_stream.rs | 41 ++++-
core/common/src/commands/streams/update_stream.rs | 15 +-
core/common/src/commands/topics/create_topic.rs | 59 +++++--
core/common/src/commands/topics/update_topic.rs | 55 ++++--
core/common/src/commands/users/change_password.rs | 43 ++++-
core/common/src/commands/users/create_user.rs | 78 ++++++---
core/common/src/commands/users/login_user.rs | 193 ++++++++++++++++-----
.../src/commands/users/update_permissions.rs | 21 ++-
core/common/src/commands/users/update_user.rs | 41 ++++-
core/common/src/types/identifier/mod.rs | 77 ++++++--
core/common/src/types/message/message_view.rs | 78 ++++-----
core/common/src/types/message/messages_batch.rs | 7 +-
.../common/src/types/message/messages_batch_mut.rs | 38 ++--
core/common/src/types/message/partitioning.rs | 147 +++++++++++++---
.../src/clients/binary_personal_access_tokens.rs | 30 +++-
.../handlers/messages/send_messages_handler.rs | 47 +++--
core/server/src/http/http_shard_wrapper.rs | 5 +-
.../apache/iggy/client/BaseIntegrationTest.java | 89 ++++++++++
.../client/async/AsyncClientIntegrationTest.java | 6 +-
.../iggy/client/async/AsyncPollMessageTest.java | 8 +-
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 146 ++++++++++------
.../iggy/client/blocking/IntegrationTest.java | 56 +-----
.../http/ConsumerGroupsHttpClientTest.java | 2 +-
.../http/ConsumerOffsetsHttpClientTest.java | 2 +-
.../client/blocking/http/HttpClientFactory.java | 15 +-
.../blocking/http/MessagesHttpClientTest.java | 2 +-
.../blocking/http/PartitionsHttpClientTest.java | 2 +-
.../http/PersonalAccessTokensHttpClientTest.java | 2 +-
.../client/blocking/http/StreamHttpClientTest.java | 2 +-
.../client/blocking/http/SystemHttpClientTest.java | 2 +-
.../client/blocking/http/TopicsHttpClientTest.java | 2 +-
.../client/blocking/http/UsersHttpClientTest.java | 2 +-
.../blocking/tcp/ConsumerGroupsTcpClientTest.java | 2 +-
.../blocking/tcp/ConsumerOffsetsTcpClientTest.java | 2 +-
.../blocking/tcp/IggyTcpClientBuilderTest.java | 44 ++---
.../client/blocking/tcp/MessagesTcpClientTest.java | 2 +-
.../blocking/tcp/PartitionsTcpClientTest.java | 2 +-
.../tcp/PersonalAccessTokensTcpClientTest.java | 2 +-
.../client/blocking/tcp/StreamTcpClientTest.java | 2 +-
.../client/blocking/tcp/SystemTcpClientTest.java | 2 +-
.../iggy/client/blocking/tcp/TcpClientFactory.java | 17 +-
.../client/blocking/tcp/TopicsTcpClientTest.java | 2 +-
.../client/blocking/tcp/UsersTcpClientTest.java | 2 +-
56 files changed, 1138 insertions(+), 479 deletions(-)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/BaseIntegrationTest.java
