我安装ApachePulsar之后用pulsar-io-jdbc-2.5.1.nar测试消息导入到MySQL,但是一致消费不成功,检查发现是sink连接器没运行。

javaMr 发布于 05/16 17:42
阅读 93
收藏 0

我安装ApachePulsar之后用pulsar-io-jdbc-2.5.1.nar测试消息导入到MySQL,但是一致消费不成功,检查发现是sink连接器没运行。

$ bin/pulsar-admin sinks status --tenant public --namespace default --name pulsar-mysql-jdbc-sink

通过命令查询运行状态得到以下内容

bin/pulsar-admin sinks status --tenant public --namespace default --name pulsar-mysql-jdbc-sink
{
  "numInstances" : 1,
  "numRunning" : 0,
  "instances" : [ {
    "instanceId" : 0,
    "status" : {
      "running" : false,
      "error" : "UNAVAILABLE: io exception",
      "numRestarts" : 0,
      "numReadFromPulsar" : 0,
      "numSystemExceptions" : 0,
      "latestSystemExceptions" : [ ],
      "numSinkExceptions" : 0,
      "latestSinkExceptions" : [ ],
      "numWrittenToSink" : 0,
      "lastReceivedTime" : 0,
      "workerId" : "c-standalone-fw-localhost-8080"
    }
  } ]
}

 

加载中
0
StreamNative
StreamNative

你好,请问问题解决了吗?可以关注 Apache Pulsar 和 StreamNative 的gzh,添加机器人好友进 Pulsar 交流群,可快速免费解答Pulsar运维中遇到的问题

 

0
StreamNative
StreamNative

或者可以在Github上提issue,方便提供描述和追踪:https://github.com/apache/pulsar

OSCHINA
登录后可查看更多优质内容
返回顶部
顶部