[sjvanrossum]

Removes the ConsumerSpEL and ProducerSpEL helpers which are no longer of any use since upgrading the minimum supported version of Kafka to 3.9.2.

[github-actions]

📋 Review Summary

This PR cleanly removes the obsolete ConsumerSpEL and ProducerSpEL reflection shims in KafkaIO, replacing reflective calls with direct invocations against the modern kafka-clients API. The refactoring preserves existing exception handling and transaction semantics while simplifying record deserialization, header coding, and EOS sink management.

🔍 General Feedback

• Direct exception handling for ProducerFencedException, OutOfOrderSequenceException, and AuthorizationException in KafkaExactlyOnceSink accurately preserves the prior behavior of bypassing abortTransaction() and closing the producer in the outer handler.
• Moving offsetForTime to KafkaIOUtils and using RecordHeaders directly in KafkaRecordCoder and ProducerRecordCoder eliminates unnecessary reflection and temporary ConsumerRecord allocations.
• No functional bugs or regressions identified.

---

💡 Tip: Comment /gemini review on this pull request to trigger a new Gemini code review.

[github-actions]

Assigning reviewers:

R: @damccorm for label java.
Backup reviewer: chamikaramj (if the main reviewer is unresponsive, you can escalate to them by tagging their username)

Note: If you would like to opt out of this review, comment assign to next reviewer.

Available commands:

• stop reviewer notifications - opt out of the automated review tooling
• remind me after tests pass - tag the comment author after tests pass
• waiting on author - shift the attention set back to the author (any comment or push by the author will return the attention set to the reviewers)

The PR bot will only process comments in the main thread (not review comments).

[Abacn]

Thanks!