This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch feat/gateways-3546-delete-topics-only
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 2661b5ed4 feat(gateways): Kafka Gateway add DeleteTopics API key that
deletes the Iggy topic only
add 1cd19ce86 perf(java): build header length error text only on failure
(#4382)
add 0b82cd666 feat(partitions)!: fence ownership and history changes
(#4456)
add 0c1f135f8 Merge branch 'master' into
feat/gateways-3546-delete-topics-only
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1 +
bdd/go/tests/tcp_test/consumers_steps.go | 17 +-
bdd/go/tests/tcp_test/messages_feature_send.go | 4 +-
core/bench/src/actors/consumer/client/low_level.rs | 5 +-
core/binary_protocol/Cargo.toml | 1 +
core/binary_protocol/src/codes.rs | 2 +
core/binary_protocol/src/consensus/header.rs | 107 +-
core/binary_protocol/src/consensus/operation.rs | 32 +-
core/binary_protocol/src/consensus/request.rs | 4 +-
core/binary_protocol/src/dispatch.rs | 8 +-
core/binary_protocol/src/lib.rs | 1 +
core/binary_protocol/src/primitives/mod.rs | 1 +
.../src/primitives/partition_history.rs | 123 +
.../src/requests/consumer_offsets/mod.rs | 19 +
.../src/requests/messages/get_send_context.rs | 90 +
core/binary_protocol/src/requests/messages/mod.rs | 2 +
.../partitions/install_consumer_group_owner.rs | 138 +
.../binary_protocol/src/requests/partitions/mod.rs | 6 +
.../partitions/retire_consumer_group_owners.rs | 151 +
.../partitions/transition_partition_history.rs | 107 +
.../src/requests/system/finalize_session.rs | 96 +
core/binary_protocol/src/requests/system/mod.rs | 2 +
.../src/responses/messages/poll_messages.rs | 36 +-
.../src/responses/messages/poll_routing.rs | 14 +-
.../src/responses/topics/get_topic.rs | 18 +-
core/common/Cargo.toml | 2 +-
core/common/src/consumer_group_client_state.rs | 267 +-
core/common/src/error/iggy_error.rs | 16 +
.../http/consumer_offsets/store_consumer_offset.rs | 4 +-
core/common/src/http/messages/send_messages.rs | 95 +-
.../src/traits/binary_impls/consumer_offsets.rs | 30 +-
core/common/src/traits/binary_impls/messages.rs | 135 +-
core/common/src/traits/binary_impls/mod.rs | 1 +
core/common/src/traits/binary_impls/partitions.rs | 2 +
core/common/src/traits/binary_impls/streams.rs | 1 +
core/common/src/traits/binary_impls/topics.rs | 6 +-
core/common/src/traits/binary_transport.rs | 361 +-
core/common/src/traits/consumer_offset_client.rs | 23 +-
core/common/src/traits/message_client.rs | 11 +
core/common/src/traits/partition_client.rs | 7 +
.../src/types/consumer/consumer_offset_info.rs | 12 +
core/common/src/types/message/polled_messages.rs | 45 +-
core/common/src/types/message/polling_strategy.rs | 21 +-
core/common/src/types/options/mod.rs | 129 +-
.../{durability.rs => partition_resize_policy.rs} | 25 +-
core/common/src/types/partition/mod.rs | 6 +
core/common/src/wire_conversions.rs | 1 +
core/configs/src/common/validators.rs | 42 +-
core/configs/src/server_config/cluster.rs | 3 +-
core/consensus/src/impls.rs | 71 +-
core/consensus/src/lib.rs | 5 -
core/consensus/src/observability.rs | 4 +
core/integration/src/harness/context.rs | 16 +-
core/integration/src/harness/helpers.rs | 59 +-
core/integration/src/harness/mod.rs | 1 +
.../tests/cluster/client_table_adversarial.rs | 13 +-
.../tests/cluster/client_table_restart.rs | 40 +-
.../tests/cluster/consumer_offset_quota.rs | 11 +-
.../tests/cluster/fast_primary_rejoin.rs | 2 +
core/integration/tests/cluster/partition_dedup.rs | 209 +-
.../tests/cluster/partition_primary_routing.rs | 93 +-
.../tests/connectors/fixtures/influxdb/sink_v3.rs | 11 +-
.../tests/data_integrity/storage_compat.rs | 26 +-
.../verify_consumer_group_partition_assignment.rs | 172 +-
.../tests/sdk/consumer_group_membership.rs | 145 +-
core/integration/tests/sdk/options.rs | 103 +
core/integration/tests/server/cg.rs | 12 +-
.../tests/server/consumer_offset_quota_vsr.rs | 1 +
core/integration/tests/server/http_rbac.rs | 1 +
core/integration/tests/server/http_vsr.rs | 4 +
core/integration/tests/server/raw_tcp.rs | 18 +
.../server/scenarios/authentication_scenario.rs | 14 +-
.../scenarios/invalid_consumer_offset_scenario.rs | 15 +-
.../server/scenarios/log_rotation_scenario.rs | 5 +
core/integration/tests/server/scenarios/mod.rs | 11 +
.../tests/server/scenarios/permissions_scenario.rs | 5 +
.../stale_client_consumer_group_scenario.rs | 34 +-
.../tests/server/scenarios/system_scenario.rs | 10 +-
core/metadata/src/impls/metadata.rs | 405 +-
core/metadata/src/impls/recovery.rs | 104 +-
core/metadata/src/stm/authz.rs | 17 +-
core/metadata/src/stm/consumer_group.rs | 1313 ++++--
core/metadata/src/stm/lifecycle.rs | 1671 +++++++
core/metadata/src/stm/mod.rs | 40 +-
core/metadata/src/stm/result.rs | 34 +-
core/metadata/src/stm/snapshot.rs | 50 +-
core/metadata/src/stm/stream.rs | 560 ++-
core/metadata/src/stm/user.rs | 4 +-
core/partitions/src/iggy_partition.rs | 4549 ++++++++++++++++++--
core/partitions/src/iggy_partitions.rs | 17 +-
core/partitions/src/journal.rs | 199 +-
core/partitions/src/lib.rs | 5 +
core/partitions/src/poll_plan.rs | 10 +
core/partitions/src/state_transfer.rs | 454 +-
core/partitions/src/types.rs | 8 +-
core/partitions/tests/consumer_offset_history.rs | 478 ++
.../binary_consumer_offset_client.rs | 38 +-
core/sdk/src/clients/binary_consumer_offset.rs | 16 +-
core/sdk/src/clients/client.rs | 18 +-
core/sdk/src/clients/consumer.rs | 928 +++-
core/sdk/src/clients/producer.rs | 64 +-
core/sdk/src/consumer_ext/consumer_message_ext.rs | 7 +-
core/sdk/src/http/consumer_offsets.rs | 41 +-
core/sdk/src/http/http_client.rs | 350 +-
core/sdk/src/http/messages.rs | 458 +-
core/sdk/src/http/mod.rs | 2 +
core/sdk/src/http/partitions.rs | 2 +
core/sdk/src/http/scripted_server.rs | 232 +
core/sdk/src/http/streams.rs | 1 +
core/sdk/src/http/topics.rs | 45 +-
core/sdk/src/poll_routing.rs | 411 +-
core/sdk/src/prelude.rs | 32 +-
core/sdk/src/quic/quic_client.rs | 258 +-
core/sdk/src/tcp/tcp_client.rs | 389 +-
core/sdk/src/vsr.rs | 190 +-
core/sdk/src/websocket/websocket_client.rs | 238 +-
core/server/README.md | 10 +-
core/server/config.toml | 9 +-
core/server/src/boot/mod.rs | 33 +-
core/server/src/boot/recovery.rs | 8 +-
core/server/src/consumer_group.rs | 760 +---
core/server/src/consumer_group/liveness.rs | 39 +-
core/server/src/dispatch/authz.rs | 7 +-
core/server/src/dispatch/failure.rs | 5 +-
core/server/src/dispatch/mod.rs | 175 +-
core/server/src/dispatch/partition.rs | 310 +-
core/server/src/dispatch/reads.rs | 97 +-
core/server/src/dispatch/submit.rs | 24 +-
core/server/src/http/handlers.rs | 113 +-
core/server/src/http/submit.rs | 60 +-
core/server/src/http/wire.rs | 8 +
core/server/src/lib.rs | 3 +
core/server/src/partition_helpers.rs | 5 +-
core/server/src/partition_reconciler.rs | 1152 ++++-
core/server/src/reply_frame.rs | 82 +-
core/server/src/responses.rs | 32 +-
core/server/src/server_error.rs | 2 +-
core/server/src/sysinfo_printer.rs | 12 +-
core/server/src/sysinfo_probe.rs | 25 +-
core/server_common/src/consensus_message.rs | 11 +-
core/shard/src/lib.rs | 196 +-
core/shard/src/partition_io.rs | 191 +-
core/shard/src/poll.rs | 101 +-
core/shard/src/poll/completion.rs | 6 +-
core/shard/src/poll/completion_tests.rs | 623 ++-
core/shard/src/poll/test_support.rs | 98 +-
core/shard/src/poll/timeout_tests.rs | 49 +-
core/shard/src/router.rs | 17 +-
core/simulator/src/client.rs | 33 +-
core/simulator/src/lib.rs | 492 ++-
core/simulator/src/replica.rs | 33 +-
core/simulator/src/storage/bookmark_recovery.rs | 63 +-
core/simulator/src/workload/mod.rs | 69 +-
.../src/workload/ops/create_consumer_group.rs | 14 +-
.../src/workload/ops/create_partitions.rs | 1 +
.../src/workload/ops/delete_partitions.rs | 1 +
core/simulator/src/workload/ops/update_topic.rs | 2 +-
core/simulator/src/workload/oracle.rs | 38 +-
.../apache/iggy/examples/ConsumerOffsetTest.java | 11 +-
foreign/cpp/include/iggy.hpp | 109 +-
foreign/cpp/src/client.cpp | 12 +
foreign/cpp/src/client.rs | 180 +-
foreign/cpp/src/lib.rs | 53 +
foreign/cpp/src/type_conversion.rs | 81 +-
foreign/cpp/src/type_conversions.cpp | 14 +-
foreign/cpp/tests/e2e/consumer_group.cpp | 12 +
foreign/cpp/tests/e2e/message.cpp | 2 +
foreign/cpp/tests/e2e/test_helpers.hpp | 41 +
foreign/cpp/tests/unit/unit_tests.cpp | 9 +
.../ConsumerGroupTests.cs | 6 +-
.../Helpers/ConsumerGroupAssignment.cs | 74 +
.../Iggy_SDK.Tests.Integration/OffsetTests.cs | 9 +
.../Iggy_SDK.Tests.Integration/OptionsTests.cs | 1 +
.../Vsr/VsrConsumerGroupTests.cs | 27 +-
.../Iggy_SDK/Consumers/IggyConsumer.Rented.cs | 23 +-
foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 125 +-
.../csharp/Iggy_SDK/Consumers/IggyConsumerOfT.cs | 3 +-
.../csharp/Iggy_SDK/Consumers/ReceivedMessage.cs | 14 +
.../Iggy_SDK/Consumers/ReceivedRentedMessage.cs | 10 +
.../Iggy_SDK/Contracts/Auth/GlobalPermissions.cs | 7 +-
.../Iggy_SDK/Contracts/Http/MessageSendRequest.cs | 1 +
.../Iggy_SDK/Contracts/Http/StoreOffsetRequest.cs | 1 +
...lAccessTokenResponse.cs => PartitionContext.cs} | 23 +-
.../csharp/Iggy_SDK/Contracts/PartitionResponse.cs | 3 +
.../csharp/Iggy_SDK/Contracts/PolledMessages.cs | 3 +
.../Iggy_SDK/Contracts/PolledMessagesRental.cs | 3 +
.../csharp/Iggy_SDK/Contracts/StreamPermissions.cs | 7 +-
.../csharp/Iggy_SDK/Contracts/TopicPermissions.cs | 7 +-
.../csharp/Iggy_SDK/IggyClient/IIggyConsumer.cs | 65 +
.../Iggy_SDK/IggyClient/IIggyConsumerGroup.cs | 1 +
foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs | 28 +
.../Implementations/HttpMessageStream.cs | 139 +-
.../TcpMessageStream.PollRouting.cs | 237 +-
.../Implementations/TcpMessageStream.Vsr.cs | 37 +-
.../IggyClient/Implementations/TcpMessageStream.cs | 164 +-
.../Iggy_SDK/JsonConverters/MessagesConverter.cs | 5 +
foreign/csharp/Iggy_SDK/Kinds/PollingStrategy.cs | 20 +
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 35 +-
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 1 +
.../Iggy_SDK/Vsr/ConsumerGroupClientState.cs | 67 +-
foreign/csharp/Iggy_SDK/Vsr/VsrConnection.cs | 7 +-
foreign/csharp/Iggy_SDK/Vsr/VsrError.cs | 3 +
foreign/csharp/Iggy_SDK/Vsr/VsrHeader.cs | 15 +-
foreign/csharp/Iggy_SDK/Vsr/VsrOperation.cs | 15 +-
.../ClientTests/HttpConsumerOffsetTests.cs} | 27 +-
.../ClientTests/HttpPartitionContextTests.cs | 261 ++
.../ClientTests/HttpTopicOptionsTests.cs | 2 +-
.../ConsumerSessionGenerationTests.cs | 2 +-
.../NoAssignedPartitionBackoffTests.cs | 6 +-
.../ConsumerTests/OffsetContinuationTests.cs | 380 ++
.../ConsumerTests/PartitionIncarnationTests.cs | 217 +
.../ConsumerTests/RentedConsumerTests.cs | 4 +-
.../ConsumerTests/RentedTypedConsumerTests.cs | 3 +
.../MessageBatchGoldenVectorTests.cs | 11 +-
.../Iggy_SDK_Tests/MapperTests/BinaryMapper.cs | 45 +-
.../csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs | 17 +
.../VsrTests/ConsumerGroupClientStateTests.cs | 4 +-
.../VsrTests/EndpointFailoverTests.cs | 13 +-
.../Iggy_SDK_Tests/VsrTests/GroupPollingTests.cs | 73 +-
foreign/csharp/Iggy_SDK_Tests/VsrTests/MockNode.cs | 79 +
.../VsrTests/PartitionContextTests.cs | 558 +++
.../Iggy_SDK_Tests/VsrTests/PrimaryPollingTests.cs | 220 +-
.../Iggy_SDK_Tests/VsrTests/VsrHeaderTests.cs | 14 +
.../VsrTests/VsrProtocolDriftTests.cs | 4 +
foreign/go/README.md | 8 +-
.../binary_response_deserializer.go | 31 +-
.../binary_response_deserializer_test.go | 1 +
.../vsr_response_deserializer_test.go | 5 +-
foreign/go/client/tcp/cluster.go | 10 +
foreign/go/client/tcp/tcp_core.go | 96 +-
foreign/go/client/tcp/tcp_core_review_test.go | 28 +-
foreign/go/client/tcp/tcp_core_test.go | 189 +-
foreign/go/client/tcp/tcp_group_polling.go | 9 +-
foreign/go/client/tcp/tcp_group_polling_test.go | 52 +-
foreign/go/client/tcp/tcp_messaging.go | 160 +-
foreign/go/client/tcp/tcp_offset_management.go | 60 +-
foreign/go/client/tcp/tcp_partition_management.go | 8 +-
foreign/go/client/tcp/tcp_poll_routing.go | 97 +-
foreign/go/client/tcp/tcp_poll_routing_test.go | 345 +-
foreign/go/client/tcp/tcp_testing_test.go | 24 +
foreign/go/client/tcp/tcp_topic_cache.go | 66 +-
foreign/go/client/tcp/tcp_topic_cache_test.go | 68 +-
foreign/go/contracts/client.go | 43 +-
foreign/go/contracts/message_polling.go | 11 +
foreign/go/contracts/messages.go | 1 +
foreign/go/contracts/offset.go | 8 +
foreign/go/contracts/partitions.go | 31 +-
foreign/go/errors/errors.yaml | 16 +
foreign/go/errors/errors_gen.go | 66 +
foreign/go/errors/errors_test.go | 6 +
foreign/go/internal/command/code.go | 1 +
foreign/go/internal/vsr/header.go | 13 +-
foreign/go/internal/vsr/operation.go | 18 +-
foreign/go/internal/vsr/protocol_parity_test.go | 8 +
foreign/go/tests/e2e_helpers_test.go | 33 +
foreign/go/tests/e2e_test.go | 18 +-
.../iggy/client/async/ConsumerOffsetsClient.java | 35 +
.../apache/iggy/client/async/MessagesClient.java | 14 +
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 41 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 344 +-
.../client/async/tcp/ConsumerOffsetsTcpClient.java | 108 +-
.../iggy/client/async/tcp/MessagesTcpClient.java | 88 +-
.../iggy/client/async/tcp/PartitionContexts.java | 191 +
.../iggy/client/async/tcp/PartitionsTcpClient.java | 12 +
.../apache/iggy/client/async/tcp/PollRouter.java | 102 +-
.../client/async/tcp/RawPartitionRequests.java | 170 +
.../iggy/client/async/tcp/StreamsTcpClient.java | 15 +-
.../iggy/client/async/tcp/TopicsTcpClient.java | 17 +-
.../client/async/tcp/vsr/ConsensusSession.java | 49 +-
.../iggy/client/async/tcp/vsr/VsrHeaders.java | 9 +-
.../iggy/client/async/tcp/vsr/VsrOperation.java | 8 +
.../client/async/tcp/vsr/VsrRequestEncoder.java | 12 +
.../client/blocking/ConsumerOffsetsClient.java | 30 +
.../iggy/client/blocking/IggyBaseClient.java | 3 +-
.../iggy/client/blocking/MessagesClient.java | 17 +
.../blocking/http/ConsumerOffsetsHttpClient.java | 30 +-
.../iggy/client/blocking/http/IggyHttpClient.java | 9 +-
.../client/blocking/http/InternalHttpClient.java | 69 +-
.../client/blocking/http/MessagesHttpClient.java | 83 +-
.../client/blocking/http/PartitionsHttpClient.java | 6 +-
.../iggy/client/blocking/http/SendContexts.java | 86 +
.../client/blocking/http/StreamsHttpClient.java | 5 +-
.../client/blocking/http/TopicsHttpClient.java | 5 +-
.../blocking/tcp/ConsumerOffsetsTcpClient.java | 12 +
.../org/apache/iggy/exception/IggyErrorCode.java | 5 +
.../org/apache/iggy/message/PolledMessages.java | 5 +-
.../org/apache/iggy/message/PollingStrategy.java | 30 +-
.../java/org/apache/iggy/partition/Partition.java | 3 +-
.../{Partition.java => PartitionContext.java} | 13 +-
.../org/apache/iggy/serde/BytesDeserializer.java | 21 +-
.../org/apache/iggy/serde/BytesSerializer.java | 11 +-
.../java/org/apache/iggy/serde/CommandCode.java | 7 +-
.../AsyncIggyTcpClientPartitionContextTest.java | 844 ++++
.../tcp/AsyncIggyTcpClientRawRequestTest.java | 362 ++
.../AsyncIggyTcpClientSendContextCacheTest.java | 251 ++
.../AsyncIggyTcpClientTransientFailoverTest.java | 160 +-
.../tcp/AsyncTcpConnectionLifecycleBusyTest.java | 429 ++
.../iggy/client/async/tcp/PollRouterTest.java | 266 ++
.../async/tcp/vsr/VsrRequestEncoderTest.java | 27 +-
.../http/MessagesHttpClientSendContextTest.java | 433 ++
.../client/blocking/http/ObjectMapperTest.java | 30 +
.../client/blocking/tcp/BytesSerializerTest.java | 26 +
.../blocking/tcp/ConsumerGroupsTcpClientTest.java | 30 +-
.../apache/iggy/exception/IggyErrorCodeTest.java | 4 +
.../apache/iggy/message/PollingStrategyTest.java | 36 +
.../apache/iggy/serde/BytesDeserializerTest.java | 1 +
.../iggy/serde/MessagesBatchWireFormatTest.java | 8 +-
.../org/apache/iggy/topic/TopicDetailsTest.java | 4 +-
foreign/node/README.md | 22 +-
foreign/node/src/client/client.socket.test.ts | 638 ++-
foreign/node/src/client/client.socket.ts | 364 +-
foreign/node/src/client/client.type.ts | 11 +-
foreign/node/src/index.ts | 1 +
foreign/node/src/wire/command.code.ts | 1 +
foreign/node/src/wire/command.utils.ts | 7 +-
foreign/node/src/wire/error.code.test.ts | 15 +-
foreign/node/src/wire/error.code.ts | 5 +
foreign/node/src/wire/error.utils.ts | 9 +-
foreign/node/src/wire/identifier.utils.ts | 4 +
.../node/src/wire/message/message-batch.test.ts | 16 +-
.../src/wire/message/poll-messages.command.test.ts | 73 +-
.../node/src/wire/message/poll-messages.command.ts | 30 +-
foreign/node/src/wire/message/poll.utils.ts | 8 +-
.../src/wire/message/send-messages.command.test.ts | 100 +-
.../node/src/wire/message/send-messages.command.ts | 84 +-
.../node/src/wire/offset/delete-offset.command.ts | 15 +-
.../src/wire/offset/offset-write.command.test.ts | 47 +
.../node/src/wire/offset/store-offset.command.ts | 14 +-
foreign/node/src/wire/topic/topic.utils.ts | 6 +-
foreign/node/src/wire/vsr/header.test.ts | 6 +-
foreign/node/src/wire/vsr/header.ts | 38 +-
foreign/node/src/wire/vsr/index.ts | 5 +-
foreign/node/src/wire/vsr/operation.test.ts | 4 +-
foreign/node/src/wire/vsr/operation.ts | 11 +-
foreign/php/README.md | 23 +-
foreign/php/iggy-php.stubs.php | 151 +-
foreign/php/src/client.rs | 9 +
foreign/php/src/consumer.rs | 56 +-
foreign/php/src/lib.rs | 4 +-
foreign/php/src/message_iterator.rs | 5 +-
foreign/php/src/receive_message.rs | 200 +-
foreign/php/tests/IggySdkTest.php | 96 +
foreign/python/apache_iggy.pyi | 142 +-
foreign/python/src/client.rs | 26 +-
foreign/python/src/consumer.rs | 81 +-
foreign/python/src/lib.rs | 4 +-
foreign/python/src/receive_message.rs | 189 +-
foreign/python/src/topic.rs | 8 +
foreign/python/tests/test_consumer_group.py | 21 +-
foreign/python/tests/test_message_operations.py | 56 +
foreign/python/tests/utils.py | 55 +
.../swift/Sources/Iggy/Errors/IggyErrorCode.swift | 8 +
.../swift/Sources/Iggy/Models/IggyMessage.swift | 4 +-
foreign/swift/Sources/Iggy/Models/Resources.swift | 34 +-
.../swift/Sources/Iggy/Models/TopicOptions.swift | 4 +-
foreign/swift/Tests/IggyTests/ErrorCodeTests.swift | 1 +
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 11 +-
.../swift/Tests/IggyTests/ModelVectorTests.swift | 14 +
foreign/swift/Tools/golden-vectors/src/main.rs | 16 +
gateways/kafka/src/bridge/error.rs | 24 +-
gateways/kafka/src/bridge/iggy_bridge/fetch.rs | 1 +
gateways/kafka/src/protocol/handlers/fetch.rs | 14 +-
gateways/kafka/tests/fetch_real_bridge_tests.rs | 8 +
363 files changed, 30209 insertions(+), 4334 deletions(-)
create mode 100644 core/binary_protocol/src/primitives/partition_history.rs
create mode 100644
core/binary_protocol/src/requests/messages/get_send_context.rs
create mode 100644
core/binary_protocol/src/requests/partitions/install_consumer_group_owner.rs
create mode 100644
core/binary_protocol/src/requests/partitions/retire_consumer_group_owners.rs
create mode 100644
core/binary_protocol/src/requests/partitions/transition_partition_history.rs
create mode 100644 core/binary_protocol/src/requests/system/finalize_session.rs
copy core/common/src/types/options/{durability.rs =>
partition_resize_policy.rs} (67%)
create mode 100644 core/metadata/src/stm/lifecycle.rs
create mode 100644 core/partitions/tests/consumer_offset_history.rs
create mode 100644 core/sdk/src/http/scripted_server.rs
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/Helpers/ConsumerGroupAssignment.cs
copy foreign/csharp/Iggy_SDK/Contracts/{Auth/PersonalAccessTokenResponse.cs =>
PartitionContext.cs} (61%)
copy foreign/csharp/{Iggy_SDK/Contracts/Http/StoreOffsetRequest.cs =>
Iggy_SDK_Tests/ClientTests/HttpConsumerOffsetTests.cs} (52%)
create mode 100644
foreign/csharp/Iggy_SDK_Tests/ClientTests/HttpPartitionContextTests.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/ConsumerTests/OffsetContinuationTests.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/ConsumerTests/PartitionIncarnationTests.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/VsrTests/PartitionContextTests.cs
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/PartitionContexts.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/RawPartitionRequests.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/http/SendContexts.java
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/partition/{Partition.java
=> PartitionContext.java} (70%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/AsyncIggyTcpClientPartitionContextTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/AsyncIggyTcpClientRawRequestTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/AsyncIggyTcpClientSendContextCacheTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/AsyncTcpConnectionLifecycleBusyTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/PollRouterTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/MessagesHttpClientSendContextTest.java
create mode 100644 foreign/node/src/wire/offset/offset-write.command.test.ts
