I have described it in a pull request mentioned in the original email. Pasting below: https://github.com/apache/kafka/pull/16812 Feature/add custom produce request parsers by maxfortun · Pull Request #16812 · apache/kafka github.com
Add ability to specify a custom produce request parser. 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, or a transform(such as lineage). The inline new ProduceRequest(new ProduceRequestData(new ByteBufferAccessor(buffer), version), version) was moved out of ProduceRequest.java into its own class ProduceRequestParser.java, and ProduceRequest class was augmented with the dynamic loading of a specified parser class. When no class is specified, the default one is loaded maintaining full backward compatibilty. > On Aug 14, 2024, at 2:13 PM, Chia-Ping Tsai <chia7...@gmail.com> wrote: > >> I submitted a request(https://issues.apache.org/jira/browse/INFRA-25451) for > it last week, but received no response. > > that is a known issue :( > > Maybe you can file a jira first and then create a google doc (or other > online doc) to describe your idea. > > Best, > Chia-Ping
