Hi all, I would like to introduce a minor code change to allow custom produce request parsers.
KIP: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=318606528 JIRA: https://issues.apache.org/jira/browse/KAFKA-17348 PR: https://github.com/apache/kafka/pull/16812 There are many potential benefits for this feature. A custom produce request parser would allow to intercept all incoming messages before they get into the broker and apply broker wide logic to the messages. This could be a trace, a filter, a transform(such as lineage), forcing required headers across all messages, compression, signing, encryption, or any other message manipulation before it gets into the broker. Please take a look. Any and all feedback is greatly appreciated. Thanks, Max
