See https://cwiki.apache.org/confluence/display/KAFKA/KIP-820%3A+Extend+KStream+process+with+new+Processor+API `MessagingTransformer` `HeaderEnricher` (If 3.3.0 is released in time for our RC).
