deploy/resource_customizations/platform.confluent.io/Connector/health.lua

hs = {}
if obj.status ~= nil and obj.status.state ~= nil then
    if obj.status.state == "CREATED" and obj.status.connectorState == "RUNNING" and obj.status.failedTasksCount == nil then
        hs.status = "Healthy"
        hs.message = "Connector running"
        return hs
    end
    if obj.status.state == "ERROR" then
        hs.status = "Degraded"
        if obj.status.conditions and #obj.status.conditions > 0 then
            hs.message = obj.status.conditions[1].message -- Kafka Connector only has one condition and nests the issues in the error message here
        else
            hs.message = "No conditions available"
        end
        return hs
    end
    if obj.status.failedTasksCount ~= nil and obj.status.failedTasksCount > 0 then
        hs.status = "Degraded"
        hs.message = "Connector has failed tasks"
        return hs
    end
end
hs.status = "Progressing"
hs.message = "Waiting for Kafka Connector"
return hs