This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch external-group-offsets
in repository https://gitbox.apache.org/repos/asf/iggy.git
from adc79d045 feat(server)!: store offsets of groups managed outside Iggy
add e51780a53 chore(repo): make repository skills available to Codex
(#4360)
add 7c10d8adb fix(sdk): keep a shut down client shut down (#4374)
add 0936d44cc chore(repo): bump all components to patch edge versions
after 0.9.0 (#4315)
add 815f345b3 docs: require agent review, comment replies and fewer
rebases (#4384)
add c80183499 chore(deps): Bump the go group across 2 directories with 2
updates (#4390)
add 2d7fddba5 feat(gateways): Kafka gateway Phase 1 quick-start and Docker
Compose E2E (#4372)
add a53cdc69a Merge branch 'master' into external-group-offsets
No new revisions were added by this update.
Summary of changes:
.agents/skills/connector-review | 1 +
.agents/skills/connector-runtime | 1 +
.agents/skills/connector-sdk | 1 +
.agents/skills/connector-sink | 1 +
.agents/skills/connector-source | 1 +
.agents/skills/connector-testing | 1 +
.agents/skills/connector-transform | 1 +
.agents/skills/connectors-overview | 1 +
.agents/skills/team-review | 1 +
.agents/skills/team-review-slim | 1 +
.claude/skills/connector-review/SKILL.md | 35 +--
.../skills/connector-review/agents/openai.yaml | 4 +-
.claude/skills/connector-sink/TEMPLATE.md | 2 +-
.claude/skills/team-review-slim/SKILL.md | 31 +-
.../skills/team-review-slim/agents/openai.yaml | 4 +-
.claude/skills/team-review/SKILL.md | 29 +-
.../skills/team-review/agents/openai.yaml | 4 +-
.claude/skills/team-review/references/execution.md | 80 +++++
.config/nextest.toml | 3 +
.github/workflows/_common.yml | 7 +-
.../connectors/.gitkeep => .pr4372-comments.json | 0
.pre-commit-config.yaml | 2 +-
AGENTS.md | 20 +-
CONTRIBUTING.md | 22 ++
Cargo.lock | 66 ++--
Cargo.toml | 10 +-
bdd/go/go.mod | 4 +-
bdd/go/go.sum | 8 +-
bdd/python/uv.lock | 2 +-
core/ai/mcp/Cargo.toml | 2 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/report/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/common/src/traits/client.rs | 7 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sinks/clickhouse_sink/Cargo.toml | 2 +-
core/connectors/sinks/delta_sink/Cargo.toml | 2 +-
core/connectors/sinks/doris_sink/Cargo.toml | 2 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/http_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/influxdb_sink/Cargo.toml | 2 +-
core/connectors/sinks/meilisearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/mongodb_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/rabbitmq_sink/Cargo.toml | 2 +-
core/connectors/sinks/redshift_sink/Cargo.toml | 2 +-
core/connectors/sinks/s3_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
core/connectors/sinks/surrealdb_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/http_source/Cargo.toml | 2 +-
core/connectors/sources/influxdb_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
core/integration/tests/sdk/client_lifecycle.rs | 21 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/quic/quic_client.rs | 7 +-
core/sdk/src/tcp/tcp_client.rs | 7 +-
core/sdk/src/websocket/websocket_client.rs | 16 +-
core/server/Cargo.toml | 2 +-
examples/go/go.mod | 2 +-
examples/go/go.sum | 4 +-
examples/node/package-lock.json | 2 +-
examples/python/uv.lock | 2 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
.../VsrTests/VsrProtocolDriftTests.cs | 3 +-
foreign/go/contracts/version.go | 2 +-
foreign/go/go.mod | 2 +-
foreign/go/go.sum | 4 +-
foreign/node/package-lock.json | 4 +-
foreign/node/package.json | 2 +-
foreign/python/Cargo.toml | 4 +-
foreign/python/apache_iggy.pyi | 4 -
foreign/python/pyproject.toml | 2 +-
foreign/python/src/client.rs | 4 -
foreign/python/tests/test_connectivity.py | 17 +-
foreign/python/uv.lock | 2 +-
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 12 +-
gateways/kafka/Dockerfile | 64 ++++
.../kafka/Dockerfile.dockerignore | 36 ++-
gateways/kafka/README.md | 98 ++++++
gateways/kafka/docker-compose.yml | 141 +++++++++
gateways/kafka/docs/MANUAL_TESTING.md | 35 ++-
gateways/kafka/docs/TEST_SUITE.md | 17 +-
gateways/kafka/tests/common/gateway_process.rs | 102 ++++++
gateways/kafka/tests/common/iggy_server.rs | 86 ++++--
gateways/kafka/tests/phase1_e2e_tests.rs | 341 +++++++++++++++++++++
licenserc.toml | 1 +
scripts/ci/skills.sh | 104 +++++--
web/package-lock.json | 4 +-
web/package.json | 2 +-
98 files changed, 1278 insertions(+), 294 deletions(-)
create mode 120000 .agents/skills/connector-review
create mode 120000 .agents/skills/connector-runtime
create mode 120000 .agents/skills/connector-sdk
create mode 120000 .agents/skills/connector-sink
create mode 120000 .agents/skills/connector-source
create mode 120000 .agents/skills/connector-testing
create mode 120000 .agents/skills/connector-transform
create mode 120000 .agents/skills/connectors-overview
create mode 120000 .agents/skills/team-review
create mode 120000 .agents/skills/team-review-slim
copy examples/java/gradle.properties =>
.claude/skills/connector-review/agents/openai.yaml (94%)
copy examples/java/gradle.properties =>
.claude/skills/team-review-slim/agents/openai.yaml (94%)
copy examples/java/gradle.properties =>
.claude/skills/team-review/agents/openai.yaml (94%)
create mode 100644 .claude/skills/team-review/references/execution.md
copy core/integration/tests/connectors/api/connectors/.gitkeep =>
.pr4372-comments.json (100%)
create mode 100644 gateways/kafka/Dockerfile
copy core/ai/mcp/.dockerignore => gateways/kafka/Dockerfile.dockerignore (57%)
create mode 100644 gateways/kafka/docker-compose.yml
create mode 100644 gateways/kafka/tests/common/gateway_process.rs
create mode 100644 gateways/kafka/tests/phase1_e2e_tests.rs
