Skip to content

fix: isolate per-record failures in Kafka sink transformer and guard DLQ reporter #49286

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
xinlian12 merged 13 commits into from
May 29, 2026
+544 −31

refactor: extract shared DLQ reporting into DlqReportHelper

433fec1
Select commit
Loading
Failed to load commit list.
Merged

fix: isolate per-record failures in Kafka sink transformer and guard DLQ reporter #49286

refactor: extract shared DLQ reporting into DlqReportHelper
433fec1
Select commit
Loading
Failed to load commit list.
Azure Pipelines / java - cosmos - kafka (🔒 SDLSources 🔒 Agentless Tag) succeeded May 29, 2026 in 1s

🔒 SDLSources 🔒 Agentless Tag succeeded

0 errors / 0 warnings

View more details on Azure Pipelines