You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by grosserl <gr...@hu-berlin.de> on 2019/01/08 12:28:59 UTC

Implementing a custom request

Dear all, I'm planning to implement a custom network request where a 
Consumer requests some partition metadata from a broker(s).
I would like to know if there are some references on what to consider 
when implementing a new request. Since there are already quite a range 
of different network requests,
I guess someone has figured out an efficient way of adding a new one. :)
To my knowledge I'll have to create a custom Builder class that builds 
the new request (similar to the MetadataRequest.java class), add 
corresponding API keys, and then create a new handleCustomRequest 
function which gets  the requested metadata. Does that sound about 
right? I'm not looking for code but rather things I would have to 
consider.
Best regards