2017-06-14 104 views
2

我們正試圖給定節點上啓動多個獨立卡夫卡HDFS連接器。錯誤運行多個獨立的卡夫卡HDFS連接器

對於每個連接器中,我們分別設置rest.portoffset.storage.file.filename到不同的端口和路徑。

而且卡夫卡經紀人JMX端口是9999 @

當我開始卡夫卡獨立的連接器,我得到的錯誤

Error: Exception thrown by the agent : java.rmi.server.ExportException: Port already in use: 9999; nested exception is: java.net.BindException: Address already in use (Bind failed)

雖然rest.port設置爲9100

卡夫卡版本:2.12-0.10.2.1

kafka-connect-hdfs版本:3.2.1

請幫忙。

+1

我只在Kakfa-Manager正在運行的節點上看到此問題。在只有kafka代理正在運行的節點上,rest.port選項允許多個連接器工作 – user2286963

回答

-1

您可能已經打開了您不瞭解的Kafka Connect連接。您可以通過以下方式進行檢查:

ps -ef | grep connect 

如果找到任何,請殺死這些進程。

0

We are trying to launch multiple standalone kafka hdfs connectors on a given node.

您是否考慮過在單個Kafka Connect實例中運行這些多個連接器?這可能會讓事情變得更容易

Kafka Connect本身可以處理在單個工作進程中運行多個連接器。分佈式模式下的Kafka Connect可以在單個節點上運行,也可以在多個節點上運行。