我正在研究从postgreSQL到HDFS的数据流 . 我在HDP 2.6沙箱上设置了融合环境 . 我对postgreSQL的jdbc源配置是

name=jdbc_1

connector.class=io.confluent.connect.jdbc.JdbcSourceConnector

tasks.max=1

connection.url=jdbc:postgresql://host:port/db?currentSchema=schema&user=user&password=password

mode=timestamp

timestamp.column.name=col1

validate.non.null=false

topic.prefix=psql-

连接的所有其他属性也很好，我正在运行它

./bin/connect-standalone ./etc/kafka/connect-standalone.properties ./etc/kafka-connect-jdbc/source.properties

它工作正常，并根据数据库中的表数创建主题

psql-table1

psql-table2

现在我想在所有主题上运行HDFS接收器，为postgreSQL数据库中的每个表创建单独的目录 . 但是当我用命令运行HDFS接收器时

./bin/connect-standalone ./etc/kafka/connect-standalone.properties ./etc/kafka-connect-hdfs/hdfs-postGres.properties

通过运行源我得到错误

ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:113)

org.apache.kafka.connect.errors.ConnectException: Unable to start REST server

at org.apache.kafka.connect.runtime.rest.RestServer.start(RestServer.java:214)

at org.apache.kafka.connect.runtime.Connect.start(Connect.java:53)

at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:95)

Caused by: java.net.BindException: Address already in use

at sun.nio.ch.Net.bind0(Native Method)

at sun.nio.ch.Net.bind(Net.java:433)

at sun.nio.ch.Net.bind(Net.java:425)

at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)

at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)

at org.eclipse.jetty.server.ServerConnector.openAcceptChannel(ServerConnector.java:331)

at org.eclipse.jetty.server.ServerConnector.open(ServerConnector.java:299)

at org.eclipse.jetty.server.AbstractNetworkConnector.doStart(AbstractNetworkConnector.java:80)

at org.eclipse.jetty.server.ServerConnector.doStart(ServerConnector.java:235)

at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)

at org.eclipse.jetty.server.Server.doStart(Server.java:398)

at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)

at org.apache.kafka.connect.runtime.rest.RestServer.start(RestServer.java:212)

... 2 more

如果我停止源连接并启动接收器它工作正常 . 任何人都可以帮我，我可以设置多个水槽连接器 .