#apache-kafka #apache-kafka-connect #confluent-platform
Вопрос:
У меня есть соединитель источника Кафки, использующий этот io.confluent.connect.jdbc.JdbcSourceConnector
класс. Он запускается в incrementing
режиме.
Я могу получить доступ к этому разъему через интерфейс Rest. Чтобы изучить проблему, я хочу знать текущее значение приращения этого соединителя.
Есть ли способ прочитать текущее значение приращения с помощью Rest?
Ответ №1:
Эта информация недоступна через REST, потому что нет специальных конечных точек, предоставляемых определенными соединителями, которые не были бы одинаковыми для всех других (другими словами, вы получаете только /конфигурацию, которую вы опубликовали, и ее /статус)
Если вы хотите покопаться в метаданных соединителя, вам придется использовать тему Внутренние смещения. например, см. Это сообщение о сбросе смещения источника