rgroothuijsen opened a new pull request, #12602: URL: https://github.com/apache/kafka/pull/12602
This adds an additional check if there is any metadata before MirrorSourceTask commits a record, to avoid a potential null pointer exception. This can happen, for example, if the record was filtered out by some transformation. The NPE would immediately be caught even without this check, but catching it beforehand allows the error to be handled more gracefully. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
