Я пытаюсь создать тему в Кафке. Когда я отправляю запрос на отправку сообщения в 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"
}
Я не могу решить проблему. Как я могу решить это?