Kafka-connect не может подключиться к базе данных Oracle - PullRequest
0 голосов
/ 29 октября 2019

Я пытаюсь создать тему в Кафке. Когда я отправляю запрос на отправку сообщения в Kafka-connect для создания темы, создается соединитель, но тема не создается. Когда я проверил журнал kafka-connect, я увидел следующее сообщение об ошибке:

Exception in thread "Thread-14" org.apache.kafka.connect.errors.ConnectException: java.sql.SQLRecoverableException: IO Error: The Network Adapter could not establish the connection
        at io.confluent.connect.jdbc.util.CachedConnectionProvider.getConnection(CachedConnectionProvider.java:69)
        at io.confluent.connect.jdbc.source.TableMonitorThread.updateTables(TableMonitorThread.java:141)
        at io.confluent.connect.jdbc.source.TableMonitorThread.run(TableMonitorThread.java:76)
Caused by: java.sql.SQLRecoverableException: IO Error: The Network Adapter could not establish the connection
        at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:774)
        at oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:688)
        at oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:39)
        at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:691)
        at java.sql.DriverManager.getConnection(DriverManager.java:664)
        at java.sql.DriverManager.getConnection(DriverManager.java:208)
        at io.confluent.connect.jdbc.dialect.GenericDatabaseDialect.getConnection(GenericDatabaseDialect.java:211)
        at io.confluent.connect.jdbc.util.CachedConnectionProvider.newConnection(CachedConnectionProvider.java:88)
        at io.confluent.connect.jdbc.util.CachedConnectionProvider.getConnection(CachedConnectionProvider.java:66)
        ... 2 more
Caused by: oracle.net.ns.NetException: The Network Adapter could not establish the connection
        at oracle.net.nt.ConnStrategy.execute(ConnStrategy.java:523)
        at oracle.net.resolver.AddrResolution.resolveAndExecute(AddrResolution.java:521)
        at oracle.net.ns.NSProtocol.establishConnection(NSProtocol.java:660)
        at oracle.net.ns.NSProtocol.connect(NSProtocol.java:286)
        at oracle.jdbc.driver.T4CConnection.connect(T4CConnection.java:1438)
        at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:518)
        ... 10 more
Caused by: java.io.IOException: Connection refused, socket connect lapse 1 ms. /10.206.41.145 1521 0 1 true
        at oracle.net.nt.TcpNTAdapter.connect(TcpNTAdapter.java:209)
        at oracle.net.nt.ConnOption.connect(ConnOption.java:161)
        at oracle.net.nt.ConnStrategy.execute(ConnStrategy.java:470)
        ... 15 more
Caused by: java.net.ConnectException: Connection refused
        at sun.nio.ch.Net.connect0(Native Method)
        at sun.nio.ch.Net.connect(Net.java:454)
        at sun.nio.ch.Net.connect(Net.java:446)
        at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:648)
        at java.nio.channels.SocketChannel.open(SocketChannel.java:189)
        at oracle.net.nt.TimeoutSocketChannel.<init>(TimeoutSocketChannel.java:81)
        at oracle.net.nt.TcpNTAdapter.connect(TcpNTAdapter.java:169)

Вы можете увидеть мой почтовый запрос ниже;

{
    "name": "jdbc_source_oracle_order",
    "config": {
            "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
            "connection.url":"jdbc:oracle:thin:@10.206.41.111:1521:ORCLCDB",
            "connection.user": "SYS AS SYSDBA",
            "connection.password": "123456",
            "topic.prefix": "oracle01-",
            "mode":"timestamp+incrementing",
            "table.whitelist" : "SYS.oc_order",
            "incrementing.column.name":"order_id",
            "validate.non.null": false
    }
}

Когда я проверяю состояние соединителя, список задач такжепусто:

{
    "name": "jdbc_source_oracle_order",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
        "mode": "timestamp+incrementing",
        "incrementing.column.name": "order_id",
        "topic.prefix": "oracle01-",
        "connection.password": "kafka_connect",
        "validate.non.null": "false",
        "connection.user": "kafka_connect as sysdba",
        "task.max": "3",
        "name": "jdbc_source_oracle_order",
        "connection.url": "jdbc:oracle:thin:@10.206.43.77:1521:ORCLCDB",
        "table.whitelist": "sys.oc_order"
    },
    "tasks": [],
    "type": "source"
}

Я не могу решить проблему. Как я могу решить это?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...