Add support for custom headers in messages for Kafka producer bridge.