Не удалось создать новый конфлюентный коннектор kafka oracle jdbc-source. Это дает ошибку, вызванную: java.net.BindException: адрес уже используется

Я протестировал существующий исходный коннектор jdbc по умолчанию. Он отлично работает для БД. Я хочу создать еще один исходный коннектор оракула jdbc для другой БД. Для этого я создал новый файл свойств с разными данными БД. Затем я выполнил приведенную ниже команду.

bin/connect-standalone etc/schema-registry/connect-avro-standalone.properties source-quickstart-sqlite1.properties

Ошибка:

[2020-06-20 09:43:46,751] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectStandalone:130)
org.apache.kafka.connect.errors.ConnectException: Unable to initialize REST server
        at org.apache.kafka.connect.runtime.rest.RestServer.initializeServer(RestServer.java:217)
        at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:87)
Caused by: java.io.IOException: Failed to bind to 0.0.0.0/0.0.0.0:8083
        at org.eclipse.jetty.server.ServerConnector.openAcceptChannel(ServerConnector.java:346)
        at org.eclipse.jetty.server.ServerConnector.open(ServerConnector.java:307)
        at org.eclipse.jetty.server.AbstractNetworkConnector.doStart(AbstractNetworkConnector.java:80)
        at org.eclipse.jetty.server.ServerConnector.doStart(ServerConnector.java:231)
        at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:72)
        at org.eclipse.jetty.server.Server.doStart(Server.java:385)
        at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:72)
        at org.apache.kafka.connect.runtime.rest.RestServer.initializeServer(RestServer.java:215)
        ... 1 more
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:342)
        ... 8 more

Я пробовал использовать rest.port:8089. Это также не работает.


apache-kafka apache-kafka-connect confluent-platform
person Dipanjan Das    schedule 20.06.2020    source источник

Ответы (1)


arrow_upward
1
arrow_downward

На вашем компьютере уже запущено приложение, которое подключено (привязано) к порту 8083. Вероятно, это еще один экземпляр Kafka Connect. Остановите его перед выполнением команды.

Чтобы найти приложение, прослушивающее порт, выполните lsof -i :8083, и вы получите PID. Затем вы можете просто kill при условии, что это все о локальной разработке приложений Konnect.

person madhead    schedule 21.06.2020