时间戳

首页 > 解决方案 > 使用 Rest 读取 Confluent JDBC Kafka 源连接器的当前递增值？

jdbc - 使用 Rest 读取 Confluent JDBC Kafka 源连接器的当前递增值？

问题描述

我有一个使用io.confluent.connect.jdbc.JdbcSourceConnector该类的 Kafka 源连接器。它以incrementingmode运行。

我可以通过Rest interface访问这个连接器。为了检查一个问题，我想知道这个连接器的当前增量值。

有没有办法用 Rest 读取当前的递增值？

标签： jdbcapache-kafkaapache-kafka-connectconfluent-platform

解决方案

该信息不能通过 REST 获得，因为没有特定连接器提供的特殊端点在所有其他端点中不统一（换句话说，您只能获得您发布的 /config 及其 /status）

如果您想深入研究连接器元数据，则必须使用内部偏移量主题。例如看到这篇关于重置源偏移的帖子

推荐阅读