【问题标题】:Read current incrementing value of Confluent JDBC Kafka Source Connector with Rest?使用 Rest 读取 Confluent JDBC Kafka 源连接器的当前递增值?
【发布时间】:2021-06-29 06:40:50
【问题描述】:

我有一个使用 io.confluent.connect.jdbc.JdbcSourceConnector 类的 Kafka 源连接器。它在incrementing mode 中运行。

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

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

【问题讨论】:

    标签: jdbc apache-kafka apache-kafka-connect confluent-platform


    【解决方案1】:

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

    如果您想深入了解连接器元数据,则必须使用内部偏移量主题。例如在Resetting the Source Offset上看到这篇文章

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2018-10-25
      • 2020-02-05
      • 2019-06-11
      • 1970-01-01
      • 2017-10-12
      • 2018-12-19
      • 2019-04-06
      • 2018-09-14
      相关资源
      最近更新 更多