This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch kafka-gateway-perf
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 91356b273 perf(gateways): give each Kafka producer its own Iggy client
add 7fa32654d fix(connectors): make source NACK retries configurable and
observable (#4269)
add a460e5a93 Merge branch 'master' into kafka-gateway-perf
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 | 2 +-
Cargo.toml | 2 +-
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 +-
19 files changed, 2054 insertions(+), 253 deletions(-)
