CONTRIBUTING doc says to nag :) Please check out my PR that adds server side ability to intercept incoming messages. My org needs to be able to apply lineage and certain other tiny transforms to all the messages on the server side, and this feature would allow us to adopt Kafka. The alternatives of using a client side solution(like streams) or creating a proxy in front of Kafka is a very heavy lift and we would prefer to avoid it. If there are other ways to intercept an incoming message and manipulate it, please point me in the right direction. Thanks! Max
https://github.com/apache/kafka/pull/16802 add custom produce request parsers by maxfortun · Pull Request #16802 · apache/kafka github.com