This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch replicated_crash_contract
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 7c72a787b address review
add d0fc19a26 chore(deps): Bump nlohmann_json from 3.12.0.bcr.1 to
3.12.0.bcr.2 in /foreign/cpp in the cpp group across 1 directory (#4689)
add c4d86e3ff chore(deps): Bump the python group across 3 directories with
3 updates (#4752)
add 2487036c4 feat(python): expose consumer shutdown and offset drain
timeout (#4660)
add 09b5a02c0 fix(mcp): document allowed values for poll strategy and
partitioning (#4588)
add fff4f983c test(go): cover access token command serialization (#4640)
add f451fb91e feat(example): add a multi-tenant Go producer and consumer
(#4716)
add 7bcf398ea feat(python): add sink data producer example (#4710)
add df68779fc feat(connectors): deliver sink messages at least once (#4734)
add e9479ebc0 Merge branch 'master' into replicated_crash_contract
No new revisions were added by this update.
Summary of changes:
.claude/skills/connector-sink/SKILL.md | 20 +-
.claude/skills/connectors-overview/SKILL.md | 2 +-
bdd/python/uv.lock | 56 +-
core/ai/mcp/src/service/requests.rs | 28 +-
core/connectors/runtime/README.md | 82 +-
core/connectors/runtime/src/configs/connectors.rs | 145 ++
core/connectors/runtime/src/error.rs | 15 +
core/connectors/runtime/src/main.rs | 13 +
core/connectors/runtime/src/manager/sink.rs | 11 +
core/connectors/runtime/src/sink.rs | 813 ++++++---
core/connectors/runtime/src/sink_delivery.rs | 1811 ++++++++++++++++++++
core/connectors/sdk/README.md | 26 +
core/connectors/sdk/src/lib.rs | 86 +
core/connectors/sdk/src/sink.rs | 533 +++++-
core/connectors/sinks/http_sink/README.md | 18 +-
core/connectors/sinks/http_sink/src/lib.rs | 188 +-
.../tests/connectors/fixtures/http/container.rs | 7 +
.../tests/connectors/fixtures/http/mod.rs | 6 +-
.../tests/connectors/fixtures/http/sink.rs | 71 +
core/integration/tests/connectors/fixtures/mod.rs | 7 +-
.../tests/connectors/http/http_sink_delivery.rs | 237 +++
core/integration/tests/connectors/http/mod.rs | 1 +
.../tests/connectors/stdout/stdout_sink.rs | 61 +-
examples/go/README.md | 19 +-
examples/go/common/client.go | 94 +
examples/go/common/permissions.go | 92 +
examples/go/common/permissions_test.go | 63 +
examples/go/multi-tenant/consumer/main.go | 190 ++
examples/go/multi-tenant/consumer/main_test.go | 47 +
examples/go/multi-tenant/producer/main.go | 200 +++
.../go/multi-tenant/producer/main_test.go | 38 +-
examples/python/README.md | 34 +
examples/python/pyproject.toml | 2 +-
examples/python/sink-data-producer/producer.py | 171 ++
examples/python/uv.lock | 40 +-
foreign/cpp/MODULE.bazel | 2 +-
foreign/cpp/MODULE.bazel.lock | 3 +-
foreign/go/internal/command/access_token_test.go | 87 +-
foreign/python/README.md | 15 +-
foreign/python/apache_iggy.pyi | 6 +-
foreign/python/src/client.rs | 12 +-
foreign/python/tests/test_consumer_group.py | 36 +-
foreign/python/uv.lock | 50 +-
43 files changed, 4999 insertions(+), 439 deletions(-)
create mode 100644 core/connectors/runtime/src/sink_delivery.rs
create mode 100644 core/integration/tests/connectors/http/http_sink_delivery.rs
create mode 100644 examples/go/common/client.go
create mode 100644 examples/go/common/permissions.go
create mode 100644 examples/go/common/permissions_test.go
create mode 100644 examples/go/multi-tenant/consumer/main.go
create mode 100644 examples/go/multi-tenant/consumer/main_test.go
create mode 100644 examples/go/multi-tenant/producer/main.go
copy foreign/go/internal/command/segment.go =>
examples/go/multi-tenant/producer/main_test.go (51%)
create mode 100644 examples/python/sink-data-producer/producer.py
