Hi all, I would like to start a discussions on KIP-1205: Improve RecordHeader to be Thread-Safe:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1205%3A+Improve+RecordHeader+to+be+Thread-Safe This proposal uses double-checked locking and volatile to make RecordHeader thread-safe. Best, Ming-Yen