Add REST Endpoint for Health check etc in Kafka Connect app

[YG Che <ch...@gmail.com>]

Hi, I'd like to add a REST Endpoint for Health check in our Kafka Connect application. 
One way to do that is to implement ConnectRestExtension interface, but the problem is only ConnectRestExtensionContext will be passed in to the class, there is so few info contained in ConnectClusterState.
Is there a way to add a REST Endpoint easily? Ideally I'd like to pass in the Herder object, from there I can get most of the Kafka status. I'd also like to reuse the RestServer from Kafka as we implemented some security patch to it, don't want to create a new RestServer/JettyServer, that will be too heavyweight for this task. Thanks.

Re: Add REST Endpoint for Health check etc in Kafka Connect app

[Ning Zhang <ni...@gmail.com>]

Hi YG, it seems current Kafka Connect already provided simple REST endpoint for connector and task level status (running / stopped / ....): 
https://docs.confluent.io/5.5.0/connect/managing/monitoring.html

Is there any other info about Kafka Connect you care about?

On 2020/12/31 19:36:38, YG Che <ch...@gmail.com> wrote: 
> Hi, I'd like to add a REST Endpoint for Health check in our Kafka Connect application. 
> One way to do that is to implement ConnectRestExtension interface, but the problem is only ConnectRestExtensionContext will be passed in to the class, there is so few info contained in ConnectClusterState.
> Is there a way to add a REST Endpoint easily? Ideally I'd like to pass in the Herder object, from there I can get most of the Kafka status. I'd also like to reuse the RestServer from Kafka as we implemented some security patch to it, don't want to create a new RestServer/JettyServer, that will be too heavyweight for this task. Thanks.
>