使用 Rest 读取 Confluent JDBC Kafka Source Connector 的当前增量值?
Read current incrementing value of Confluent JDBC Kafka Source Connector with Rest?
我有一个使用 io.confluent.connect.jdbc.JdbcSourceConnector
class. It is run in incrementing
mode 的 Kafka 源连接器。
我可以通过 Rest interface 访问此连接器。要检查一个问题,我想知道此连接器的当前增量值。
有没有办法用 Rest 读取当前递增的值?
该信息无法通过 REST 获得,因为没有特定连接器提供的特殊端点在所有其他连接器中不统一(换句话说,您只能获得您 posted 的 /config 及其/状态)
如果您想深入了解连接器元数据,则必须使用内部偏移量主题。例如在 Resetting the Source Offset
上查看此 post
我有一个使用 io.confluent.connect.jdbc.JdbcSourceConnector
class. It is run in incrementing
mode 的 Kafka 源连接器。
我可以通过 Rest interface 访问此连接器。要检查一个问题,我想知道此连接器的当前增量值。
有没有办法用 Rest 读取当前递增的值?
该信息无法通过 REST 获得,因为没有特定连接器提供的特殊端点在所有其他连接器中不统一(换句话说,您只能获得您 posted 的 /config 及其/状态)
如果您想深入了解连接器元数据,则必须使用内部偏移量主题。例如在 Resetting the Source Offset
上查看此 post