Search code examples
jdbcapache-kafkaapache-kafka-connectconfluent-platform

Read current incrementing value of Confluent JDBC Kafka Source Connector with Rest?

I have a Kafka Source Connector using the io.confluent.connect.jdbc.JdbcSourceConnector class. It is run in incrementing mode.

I can access this connector via the Rest interface. To examine a problem I want to know the current incrementing value of this connector.

Is there a way to read the current incrementing value with Rest?

Solution

  • That information is not available via REST because there are no special endpoints that specific connectors provide that are not uniform across all others (in other words, you only get the /config that you posted and its /status)

    If you would like to dig into the connector metadata, you'll have to consume the internal offsets topic. e.g. see this post on Resetting the Source Offset