Details
-
Bug
-
Resolution: Done
-
Minor
-
1.6.1.Final
-
None
-
False
-
False
-
Undefined
Description
Hello there, We have provided database.url in config file and ran into below errors.
java.base/java.lang.Thread.run(Thread.java:834)\nCaused by: java.lang.NumberFormatException: null\n\tat java.base/java.lang.Integer.parseInt(Integer.java:614)\n\tat java.base/java.lang.Integer.valueOf(Integer.java:983)\n\tat io.debezium.config.Configuration.lambda$getInteger$7(Configuration.java:1283)\n\tat io.debezium.config.Configuration.getInteger(Configuration.java:1209)\n\tat io.debezium.config.Configuration.getInteger(Configuration.java:1283)\n\tat io.debezium.jdbc.JdbcConfiguration.getPort(JdbcConfiguration.java:335)\n\tat io.debezium.connector.oracle.logminer.LogMinerHelper.createFlushConnection(LogMinerHelper.java:375)\n\tat
This is resolved by providing database.port along with database.ur in config.
Configuration that was used to generate the error was:
database.connection.adapter: logminer database.dbname: C01T3DBA database.history.consumer.sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="" password=""; database.history.consumer.sasl.mechanism: SCRAM-SHA-512 database.history.consumer.security.protocol: SASL_SSL database.history.consumer.ssl.endpoint.identification.algorithm: "" database.history.consumer.ssl.truststore.location: database.history.consumer.ssl.truststore.password: database.history.kafka.bootstrap.servers: database.history.kafka.topic: debezium.oracle database.history.producer.sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="" password=""; database.history.producer.sasl.mechanism: SCRAM-SHA-512 database.history.producer.security.protocol: SASL_SSL database.history.producer.ssl.endpoint.identification.algorithm: "" database.history.producer.ssl.truststore.location: database.history.producer.ssl.truststore.password: database.password: database.pdb.name: DBAPOC1 database.server.name: dbzpocsrvr database.url: jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=dbserver-scan1)(PORT=1521))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=C01T3DBA))) database.user: * poll.interval.ms: "1000" rac.nodes: ip1,ip2,ip3,ip4,ip5,ip6 snapshot.locking.mode: shared table.include.list: DBZUSR.TEMP tasksMax: 1
