Неверное значение java.sql.SQLException: реквестер приложения не может установить соединение - PullRequest
Новая
       16

Неверное значение java.sql.SQLException: реквестер приложения не может установить соединение

0 голосов
/ 27 апреля 2018

jar-файл jdbc для ibm db2 as400 находится по адресу: 

/confluent-4.1.0/share/java/kafka-connect-jdbc\jt400.jar

I am trying to configure the source file from Json file 
{ 
"name":"SOURCE_NAME", 
"config":{ 
"connector.class":"io.confluent.connect.jdbc.JdbcSourceConnector", 
"tasks.max":"1", 
"topic.prefix":"TOPIC_NAME", 
"connection.url":"jdbc:as400://IP_ADDRESS:PORT;libraries=DATABASE;", 
"connection.user":"USER_NAME", 
"connection.password":"PASSWORD", 
"key.converter": "io.confluent.connect.avro.AvroConverter", 
"key.converter.schema.registry.url": "http://localhost:8081", 
"value.converter": "io.confluent.connect.avro.AvroConverter", 
"value.converter.schema.registry.url": "http://localhost:8081", 
"log4j.logger.io.confluent.connect.jdbc":"DEBUG", 
"mode": "incrementing", 
"incrementing.column.name": "ID", 
"query": "SELECT * FROM TABLE", 
"poll.interval.ms": "60000", 
"batch.max.rows": "10000", 
"table.types": "TABLE", 
"plugin.path":"/confluent-4.1.0/share/java" 
} 
}

Я получаю ошибку 

{"error_code":400,"message":"Connector configuration is invalid and contains the following 2 error(s): 
Invalid value java.sql.SQLException: The application requester cannot establish the connection. (Connection refused (Connection refused)) for configuration Couldn't open connection to jdbc:as400://IP_ADDRESS:PORT/DATABASE 
Invalid value java.sql.SQLException: The application requester cannot establish the connection. (Connection refused (Connection refused)) for configuration Couldn't open connection to jdbc:as400://IP_ADDRESS:PORT/DATABASE 
You can also find the above list of errors at the endpoint `/{connectorType}/config/validate`"}

Я успешно настроил исходники Connect для Microsoft SQL Server, и конфигурации кажутся очень похожими. Что здесь может пойти не так.

Ответы [ 2 ]

0 голосов
/ 11 января 2019

В настоящее время Kafka-jdbc-connector (Confluent) не поддерживает DB2 AS400 / iseries. если вы хотите работать с db2 AS400, добавьте ' as400 ' в поставщики диалектов as400, добавьте зависимость ' jt400 ' в pom.xml и загрузите " com.ibm". as400.access.AS400JDBCDriver"в классе" GenericDatabaseDialect "перед установлением соединения. Добавление провайдера в DB2 Dialect 

 public Provider() {
  super(Db2DatabaseDialect.class.getSimpleName(), "db2", "db2j", "ibmdb","as400");
}

Добавление драйвера AS400 Jdbc в базовый диалект базы данных 

    try {
  Class.forName("com.ibm.as400.access.AS400JDBCDriver");
} catch (ClassNotFoundException e) {
  throw new SQLException("AS400JDBC Driver Not found");
}
0 голосов
/ 15 ноября 2018

На данный момент Kafka-Connect не поддерживает AS400. Если вам нужна поддержка AS400, добавьте AS400 под диалект db2 в разъеме JDBC и восстановите разъем

...