hutiefang76 opened a new pull request, #17033: URL: https://github.com/apache/iceberg/pull/17033
Fixes #16354. This updates the Kafka Connect sink commit thread names to include the connector name: - coordinator threads now use `iceberg-coord-<connector-name>` when started by a committer - committer worker pool threads now use `iceberg-committer-<connector-name>-%d` This makes thread dumps and worker logs easier to attribute when multiple Iceberg sink connectors run in the same Kafka Connect worker. The existing package-private `CoordinatorThread(Coordinator)` constructor is kept unchanged for existing tests/internal callers. Validation: - `JAVA_HOME=$(/usr/libexec/java_home -v 17) ./gradlew :iceberg-kafka-connect:iceberg-kafka-connect:test --tests org.apache.iceberg.connect.channel.TestCoordinatorThread --tests org.apache.iceberg.connect.channel.TestCommitterImpl --no-daemon` - `JAVA_HOME=$(/usr/libexec/java_home -v 17) ./gradlew :iceberg-kafka-connect:iceberg-kafka-connect:spotlessCheck --no-daemon` - `git diff --check` --- **AI Disclosure** - Model: GPT-5 - Platform/Tool: Codex - Human Oversight: fully reviewed - Prompt Summary: Implement a small Kafka Connect thread naming fix for Apache Iceberg issue #16354 with local tests and project-style checks. -- 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]
