This is an automated email from the ASF dual-hosted git repository. numinnex pushed a commit to branch topic_metrics in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 70675dd3a62a0707a4b4596fb974c041c8b99e18 Merge: 8c558228b 7fa32654d Author: Grzegorz Koszyk <[email protected]> AuthorDate: Tue Oct 13 08:26:41 2026 +0200 Merge branch 'master' into topic_metrics .claude/skills/connector-runtime/SKILL.md | 8 +- .claude/skills/connector-source/SKILL.md | 23 +- Cargo.lock | 3 +- Cargo.toml | 3 +- .../consumer_offsets/delete_consumer_offset.rs | 3 + core/common/src/types/consumer/consumer_kind.rs | 7 +- core/connectors/runtime/src/main.rs | 8 +- core/connectors/runtime/src/manager/source.rs | 128 ++- core/connectors/runtime/src/source.rs | 519 +++++++++- core/connectors/sdk/Cargo.toml | 2 +- core/connectors/sdk/README.md | 14 +- core/connectors/sdk/src/lib.rs | 9 + core/connectors/sdk/src/source.rs | 1046 ++++++++++++++++++-- .../connectors/sinks/influxdb_sink/dependencies.md | 2 +- core/connectors/sources/http_source/README.md | 29 +- core/connectors/sources/http_source/config.toml | 3 + core/connectors/sources/http_source/src/lib.rs | 244 ++++- .../sources/http_source/src/management.rs | 41 +- core/connectors/sources/http_source/src/server.rs | 180 +++- .../sources/influxdb_source/dependencies.md | 2 +- .../tests/connectors/runtime/http_state.rs | 45 +- core/integration/tests/sdk/consumer_offset.rs | 297 +++++- core/integration/tests/server/mod.rs | 2 +- .../tests/server/scenarios/permissions_scenario.rs | 2 +- core/sdk/Cargo.toml | 1 + core/sdk/src/http/consumer_groups.rs | 9 +- core/sdk/src/http/consumer_offsets.rs | 108 +- core/sdk/src/http/messages.rs | 14 +- core/sdk/src/http/mod.rs | 1 + core/sdk/src/http/partitions.rs | 5 +- core/sdk/src/http/path.rs | 46 + core/sdk/src/http/segments.rs | 5 +- core/sdk/src/http/streams.rs | 3 +- core/sdk/src/http/topics.rs | 5 +- core/server/src/dispatch/failure.rs | 7 +- core/server/src/http/handlers.rs | 86 +- core/server/src/http/wire.rs | 171 +++- 37 files changed, 2648 insertions(+), 433 deletions(-)
