Считайте текущее увеличивающееся значение соединителя источника JDBC Кафки с Rest?

#apache-kafka #apache-kafka-connect #confluent-platform

Вопрос:

У меня есть соединитель источника Кафки, использующий этот io.confluent.connect.jdbc.JdbcSourceConnector класс. Он запускается в incrementing режиме.

Я могу получить доступ к этому разъему через интерфейс Rest. Чтобы изучить проблему, я хочу знать текущее значение приращения этого соединителя.

Есть ли способ прочитать текущее значение приращения с помощью Rest?

Ответ №1:

Эта информация недоступна через REST, потому что нет специальных конечных точек, предоставляемых определенными соединителями, которые не были бы одинаковыми для всех других (другими словами, вы получаете только /конфигурацию, которую вы опубликовали, и ее /статус)

Если вы хотите покопаться в метаданных соединителя, вам придется использовать тему Внутренние смещения. например, см. Это сообщение о сбросе смещения источника