Flink 1.18 register custom API endpoint handler

14 Views Asked by At

As per this I have created classes which implements

To add new requests, one needs to

  • add a new MessageHeaders class which serves as an interface for the new request,

  • add a new AbstractRestHandler class which handles the request according to the added MessageHeaders class,

  • add the handler to org.apache.flink.runtime.webmonitor.WebMonitorEndpoint#initializeHandlers().

but not sure how to do #3 of above, How can I add my own handler to which will support custom rest endpoint to serve the requests?

There question is similar to Flink - Expose new custom REST API.

I have tried to find anything which will take my implpementation of AbstractRestHandler as parameter but found nothing within WebMonitorEndpoint

0

There are 0 best solutions below