soumyajit-sahu opened a new pull request, #16355:
URL: https://github.com/apache/iceberg/pull/16355

   ## Problem
   When multiple Iceberg sink connectors run in the same Kafka Connect worker 
process, all
   coordinator threads share the same name `iceberg-coord` and all committer 
threads share
   names like `iceberg-committer-0`, `iceberg-committer-1`, etc.
   This makes log-based debugging difficult: when a coordinator fails to commit 
or a committer
   thread throws an error, the log output gives no indication of which 
connector is responsible.
   ## Proposed Change
   Include the connector name in the thread names:
   - `CoordinatorThread`: rename from `iceberg-coord` → 
`iceberg-coord-<connectorName>`
   - Committer `ThreadPoolExecutor` inside `Coordinator`: rename from 
`iceberg-committer-%d` → `iceberg-committer-<connectorName>-%d`
   ## Impact
   With this change, operators running multiple connectors on the same worker 
can immediately
   identify which connector's coordinator or committer thread is present in a 
log line, without
   needing additional context or MDC instrumentation.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to