feat(connectors): restart connector with new config without runtime restart#2781

Merged

mmodzelewski merged 24 commits intoapache:masterfrom

seokjin0414:2417-connector-restart-with-new-config

Mar 9, 2026

Commits on Mar 1, 2026

refactor(connectors): add iggy_clients and state_path to RuntimeContext
seokjin0414
committed
refactor(connectors): add lifecycle fields to SinkDetails and SourceDetails
seokjin0414
committed
feat(connectors): add shutdown channel to sink consume loop
seokjin0414
committed
refactor(connectors): store Arc<Container> in Manager for restart support
seokjin0414
committed
feat(connectors): add stop/start/restart methods to SinkManager
seokjin0414
committed
feat(connectors): add stop/start/restart methods to SourceManager
seokjin0414
committed
feat(connectors): add POST /restart API endpoints for sink and source connectors
seokjin0414
committed
refactor(connectors): replace direct shutdown with Manager-based stops
seokjin0414
committed
refactor(connectors): fmt and clippy fixes for restart support
seokjin0414
committed
test(connectors): add unit tests for SinkManager and SourceManager
seokjin0414
committed
fix(connectors): eliminate race condition in initial startup handle storage
seokjin0414
committed
fix(connectors): prevent resource leak in source handle() when producer is None
seokjin0414
committed
refactor(connectors): add restart concurrency guard to SinkDetails and SourceDetails
seokjin0414
committed
refactor(connectors): extract spawn_consume_tasks and reuse setup_sink_consumers in init
seokjin0414
committed
refactor(connectors): extract spawn_source_handler and reuse setup_source_producer in init
seokjin0414
committed
test(connectors): add restart integration test for sink connector
seokjin0414
committed
fix(connectors): improve restart robustness with error reporting and shutdown safety
seokjin0414
committed
refactor(connectors): code review fixes for restart robustness
seokjin0414
committed
fix(connectors): fix source false error on shutdown and startup handle race
seokjin0414
committed

Commits on Mar 9, 2026

Merge branch 'master' into 2417-connector-restart-with-new-config
mmodzelewski
authored

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat(connectors): restart connector with new config without runtime restart#2781

feat(connectors): restart connector with new config without runtime restart#2781
mmodzelewski merged 24 commits intoapache:masterfrom
seokjin0414:2417-connector-restart-with-new-config

Commits on Mar 1, 2026

refactor(connectors): add iggy_clients and state_path to RuntimeContext

refactor(connectors): add lifecycle fields to SinkDetails and SourceDetails

feat(connectors): add shutdown channel to sink consume loop

refactor(connectors): store Arc<Container> in Manager for restart support

feat(connectors): add stop/start/restart methods to SinkManager

feat(connectors): add stop/start/restart methods to SourceManager

feat(connectors): add POST /restart API endpoints for sink and source connectors

refactor(connectors): replace direct shutdown with Manager-based stops

refactor(connectors): fmt and clippy fixes for restart support

test(connectors): add unit tests for SinkManager and SourceManager

fix(connectors): eliminate race condition in initial startup handle storage

fix(connectors): prevent resource leak in source handle() when producer is None

refactor(connectors): add restart concurrency guard to SinkDetails and SourceDetails

refactor(connectors): extract spawn_consume_tasks and reuse setup_sink_consumers in init

refactor(connectors): extract spawn_source_handler and reuse setup_source_producer in init

test(connectors): add restart integration test for sink connector

fix(connectors): improve restart robustness with error reporting and shutdown safety

refactor(connectors): code review fixes for restart robustness

fix(connectors): fix source false error on shutdown and startup handle race

Commits on Mar 6, 2026

Merge branch 'master' into 2417-connector-restart-with-new-config

refactor(connectors): rename details_arc to details in manager modules

refactor(connectors): use try_lock for restart guard to avoid queuing

test(connectors): add parallel restart test and move helpers to bottom

Commits on Mar 9, 2026

Merge branch 'master' into 2417-connector-restart-with-new-config