[FLUME-3435] Allow KafkaSink to include timestamp and KafkaHeaders

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.1
• Fix Version/s: 1.11.0
• Component/s: Sinks+Sources
• Assignee: Ralph Goers
• Reporter: Ralph Goers
• Created: 26/Aug/22 05:16
• Updated: 08/Oct/22 04:00
• Resolved: 08/Oct/22 02:15

Description

With the upgrade to Kafka 2.7.2 the ProducerRecord can now include a timestamp and Kafka headers. These should be made available to callers of the sink.