Hi! We wrote a wrapper around the kafka writer to add client-side schema validation. In the process we noticed that there was no way to change a kafka record's timestamp when writing. So we extended spark-sql-kafka to support it and would love to hear your feedback.
JIRA: https://issues.apache.org/jira/browse/SPARK-50160 GitHub: https://github.com/apache/spark/pull/48695 -- Peter Fischer (he/him) Senior Software Engineer, Search Platform Wikimedia Foundation
