This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch metadata_dev
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 599d65b03 squash
add c0ebce364 feat(integration): detect server crashes during tests and
dump logs (#2536)
add 111ccefed fix(python): update python version to 3.10, clean up
examples (#2532)
add a878a4da8 fix(connectors): add known secrets to env config reader
(#2538)
add 8664e0fec docs(js): add JSDoc comments (#2534)
add 28c3f67da fix(server,sdk): handle stale client in consumer group
operations (#2547)
add a1b65e8e6 Merge branch 'master' into metadata_dev
No new revisions were added by this update.
Summary of changes:
.../actions/python-maturin/pre-merge/action.yml | 7 +-
Cargo.lock | 4 +-
DEPENDENCIES.md | 4 +-
core/connectors/runtime/src/configs/runtime.rs | 7 +-
core/integration/src/test_server.rs | 45 +++
core/integration/tests/server/mod.rs | 84 ++++--
core/integration/tests/server/scenarios/mod.rs | 1 +
.../stale_client_consumer_group_scenario.rs | 303 +++++++++++++++++++++
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/consumer.rs | 19 +-
core/server/Cargo.toml | 2 +-
core/server/src/quic/listener.rs | 6 +-
core/server/src/shard/system/utils.rs | 9 +
.../server/src/streaming/clients/client_manager.rs | 6 +-
core/server/src/tcp/connection_handler.rs | 8 +-
core/server/src/websocket/connection_handler.rs | 2 +-
foreign/node/src/client/client.connection.ts | 80 ++++++
foreign/node/src/client/client.debug.ts | 4 +
foreign/node/src/client/client.socket.ts | 101 +++++++
foreign/node/src/client/client.ts | 66 ++++-
foreign/node/src/client/client.type.ts | 74 +++++
foreign/node/src/client/client.utils.ts | 29 ++
foreign/node/src/debug-send.ts | 2 +-
foreign/node/src/type.utils.ts | 14 +
foreign/node/src/wire/command.utils.ts | 20 +-
.../wire/consumer-group/create-group.command.ts | 13 +
.../wire/consumer-group/delete-group.command.ts | 13 +
.../consumer-group/ensure-group.virtual.command.ts | 16 +-
.../src/wire/consumer-group/get-group.command.ts | 13 +
.../src/wire/consumer-group/get-groups.command.ts | 12 +
.../node/src/wire/consumer-group/group.utils.ts | 34 +++
.../src/wire/consumer-group/join-group.command.ts | 13 +
.../src/wire/consumer-group/leave-group.command.ts | 13 +
foreign/node/src/wire/identifier.utils.ts | 28 +-
.../wire/message/flush-unsaved-buffers.command.ts | 13 +
foreign/node/src/wire/message/header.type.ts | 23 ++
foreign/node/src/wire/message/header.utils.ts | 108 +++++++-
foreign/node/src/wire/message/iggy-header.utils.ts | 39 ++-
foreign/node/src/wire/message/message.utils.ts | 68 ++++-
.../node/src/wire/message/partitioning.utils.ts | 57 +++-
.../node/src/wire/message/poll-messages.command.ts | 17 ++
foreign/node/src/wire/message/poll.utils.ts | 102 ++++++-
.../node/src/wire/message/send-messages.command.ts | 14 +
foreign/node/src/wire/number.utils.ts | 81 +++++-
.../node/src/wire/offset/delete-offset.command.ts | 12 +-
foreign/node/src/wire/offset/get-offset.command.ts | 14 +
foreign/node/src/wire/offset/offset.utils.ts | 48 ++++
.../node/src/wire/offset/store-offset.command.ts | 15 +
.../src/wire/partition/create-partition.command.ts | 13 +
.../src/wire/partition/delete-partition.command.ts | 17 +-
foreign/node/src/wire/partition/partition.utils.ts | 9 +
foreign/node/src/wire/serialize.utils.ts | 20 ++
.../src/wire/session/login-with-token.command.ts | 11 +
foreign/node/src/wire/session/login.command.ts | 7 +
foreign/node/src/wire/session/login.utils.ts | 25 ++
foreign/node/src/wire/session/logout.command.ts | 7 +
.../node/src/wire/stream/create-stream.command.ts | 14 +-
.../node/src/wire/stream/delete-stream.command.ts | 11 +
.../wire/stream/ensure-stream.virtual.command.ts | 9 +-
foreign/node/src/wire/stream/get-stream.command.ts | 11 +
.../node/src/wire/stream/get-streams.command.ts | 11 +-
.../node/src/wire/stream/purge-stream.command.ts | 11 +
foreign/node/src/wire/stream/stream.utils.ts | 22 ++
.../node/src/wire/stream/update-stream.command.ts | 12 +
.../node/src/wire/token/create-token.command.ts | 12 +
.../node/src/wire/token/delete-token.command.ts | 11 +
foreign/node/src/wire/token/get-tokens.command.ts | 7 +
foreign/node/src/wire/token/token.utils.ts | 40 +++
.../node/src/wire/topic/create-topic.command.ts | 17 ++
.../node/src/wire/topic/delete-topic.command.ts | 15 +-
.../src/wire/topic/ensure-topic.virtual.command.ts | 12 +-
foreign/node/src/wire/topic/get-topic.command.ts | 14 +-
foreign/node/src/wire/topic/get-topics.command.ts | 11 +
foreign/node/src/wire/topic/purge-topic.command.ts | 12 +
foreign/node/src/wire/topic/topic.utils.ts | 73 +++++
.../node/src/wire/topic/update-topic.command.ts | 17 ++
.../node/src/wire/user/change-password.command.ts | 13 +
foreign/node/src/wire/user/create-user.command.ts | 14 +
foreign/node/src/wire/user/delete-user.command.ts | 11 +
foreign/node/src/wire/user/get-user.command.ts | 11 +
foreign/node/src/wire/user/get-users.command.ts | 9 +-
foreign/node/src/wire/user/permissions.utils.ts | 121 ++++++++
.../src/wire/user/update-permissions.command.ts | 12 +
foreign/node/src/wire/user/update-user.command.ts | 13 +
foreign/node/src/wire/user/user.utils.ts | 46 ++++
foreign/node/src/wire/uuid.utils.ts | 14 +-
foreign/python/Dockerfile.test | 3 +-
foreign/python/README.md | 18 +-
foreign/python/pyproject.toml | 8 +-
foreign/python/python_examples/README.md | 20 --
foreign/python/python_examples/consumer.py | 83 ------
.../python/python_examples/example_screenshot.png | Bin 2373561 -> 0 bytes
foreign/python/python_examples/producer.py | 110 --------
foreign/python/scripts/test.sh | 17 --
94 files changed, 2300 insertions(+), 339 deletions(-)
create mode 100644
core/integration/tests/server/scenarios/stale_client_consumer_group_scenario.rs
delete mode 100644 foreign/python/python_examples/README.md
delete mode 100644 foreign/python/python_examples/consumer.py
delete mode 100644 foreign/python/python_examples/example_screenshot.png
delete mode 100644 foreign/python/python_examples/producer.py
