This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch test_integration_crash
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 2c191f778 Merge branch 'master' into test_integration_crash
add 84d3b6766 feat(sdk): read offsets of consumer group members over the
HTTP API (#4348)
add 7fa32654d fix(connectors): make source NACK retries configurable and
observable (#4269)
add 58c6a8c56 Merge branch 'master' into test_integration_crash
No new revisions were added by this update.
Summary of changes:
.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 +-
.../get_streams.rs => sdk/src/http/path.rs} | 43 +-
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, 2620 insertions(+), 458 deletions(-)
copy core/{binary_protocol/src/requests/streams/get_streams.rs =>
sdk/src/http/path.rs} (52%)
