Worker event stream#1665

Open

mitchhs12 wants to merge 24 commits intomainfrom

worker-event-stream

Commits on Feb 5, 2026

docs: update worker events for protobuf
mitchhs12
committed
WIP: feat(worker): add Kafka event streaming for sync progress
mitchhs12
committed
feat(worker): emit lifecycle events per-table
mitchhs12
committed
feat(kafka): make partition count configurable
mitchhs12
committed
test(tests): fix E2E test to expect per-table events
mitchhs12
committed
chore(monitoring): add kafka_client to AMP_CRATES list
mitchhs12
committed
chore(deps): update Cargo.lock
mitchhs12
committed
refactor(worker): addresses PR feedback
mitchhs12
committed
fix(kafka): add error_source to error logs
mitchhs12
committed
refactor(worker): uses proto types instead for event streaming
mitchhs12
committed
refactor(kafka): consolidated kafka config into amp-config
mitchhs12
committed
docs(kafka): add status field and preqres section
mitchhs12
committed
refactor(worker): rename ProgressCallback to ProgressReporter
mitchhs12
committed
refactor(worker): change progress events from percentage-based to time-based
mitchhs12
committed
fix(dump): suppress clippy too_many_arguments warning
mitchhs12
committed
feat(worker): add SASL and TLS support for Kafka
mitchhs12
committed
docs(worker-events): align feature doc with implementation
mitchhs12
committed
add missing amp-config dep
mitchhs12
committed
docs: fix config key and proto comment accuracy
mitchhs12
committed
fix(worker): clippy
mitchhs12
committed
refactor(worker): address PR feedback
mitchhs12
committed
fix(worker): CI formatting
mitchhs12
committed
refactor(worker): address PR feedback on patterns and conventions
mitchhs12
committed
chore: trigger CI rerun
mitchhs12
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Worker event stream#1665

Worker event stream#1665
mitchhs12 wants to merge 24 commits intomainfrom
worker-event-stream

Commits on Feb 5, 2026

docs: update worker events for protobuf

WIP: feat(worker): add Kafka event streaming for sync progress

feat(worker): emit lifecycle events per-table

feat(kafka): make partition count configurable

test(tests): fix E2E test to expect per-table events

chore(monitoring): add kafka_client to AMP_CRATES list

chore(deps): update Cargo.lock

refactor(worker): addresses PR feedback

fix(kafka): add error_source to error logs

refactor(worker): uses proto types instead for event streaming

refactor(kafka): consolidated kafka config into amp-config

docs(kafka): add status field and preqres section

refactor(worker): rename ProgressCallback to ProgressReporter

refactor(worker): change progress events from percentage-based to time-based

fix(dump): suppress clippy too_many_arguments warning

feat(worker): add SASL and TLS support for Kafka

docs(worker-events): align feature doc with implementation

add missing amp-config dep

docs: fix config key and proto comment accuracy

fix(worker): clippy

refactor(worker): address PR feedback

fix(worker): CI formatting

refactor(worker): address PR feedback on patterns and conventions

chore: trigger CI rerun