which component in Pinot includes is the sink kafka connector? the reason for asking is that I'm trying to figure out what action is required from our side if Pinot fails to consume messages from a kafka topic and how do we get notified? Is there a metric to watch for?

Pinot server

ok thank you. I can see related metrics in the server section (e.g.

INVALID_REALTIME_ROWS_DROPPED

,

REALTIME_CONSUMPTION_EXCEPTIONS

)