Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-5169

debezium crashes when database is restarting

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Unresolved
    • Icon: Blocker Blocker
    • Backlog
    • 1.9.1.Final
    • oracle-connector
    • None
    • False
    • None
    • False

       

      Bug report

      we have a weekly restart of the oracle database, after the restart debezium tries to connect again to the database but after a while the connector generates the following exception,

       

      java.lang.RuntimeException: Failed to resolve Oracle database version
              at io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:161)
              at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:73)
              at io.debezium.connector.oracle.OracleConnectorTask.start(OracleConnectorTask.java:56)
              at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:130)
              at io.debezium.connector.common.BaseSourceTask.startIfNeededAndPossible(BaseSourceTask.java:207)
              at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:148)
              at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:291)
              at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:248)
              at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)
              at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:241)
              at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
              at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
              at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
              at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
              at java.base/java.lang.Thread.run(Thread.java:829)
      Caused by: java.sql.SQLRecoverableException: IO Error: Got minus one from a read call, connect lapse 38 ms., Authentication lapse 0 ms.
              at oracle.jdbc.driver.T4CConnection.handleLogonIOException(T4CConnection.java:925)
              at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:690)
              at oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:1086)
              at oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:90)
              at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:728)
              at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:649)
              at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:677)
              at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:189)
              at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$0(JdbcConnection.java:191)
              at io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:128)
              at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:882)
              at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:877)
              at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:630)
              at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:504)
              at io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:131)
              ... 14 more
      Caused by: java.io.IOException: Got minus one from a read call, connect lapse 38 ms., Authentication lapse 0 ms.
              at oracle.jdbc.driver.T4CConnection.handleLogonIOException(T4CConnection.java:920)
              ... 28 more
      Caused by: java.io.IOException: Got minus one from a read call, connect lapse 38 ms.
              at oracle.net.ns.NSProtocolNIO.negotiateConnection(NSProtocolNIO.java:202)
              at oracle.net.ns.NSProtocol.connect(NSProtocol.java:354)
              at oracle.jdbc.driver.T4CConnection.connect(T4CConnection.java:2155)
              at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:652)
              ... 27 more
      Caused by: oracle.net.ns.NetException: Got minus one from a read call
              at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1121)
              at oracle.net.ns.NIOPacket.readNIOPacket(NIOPacket.java:418)
              at oracle.net.ns.NSProtocolNIO.negotiateConnection(NSProtocolNIO.java:167)
              ... 30 more

       

      What Debezium connector do you use and what version?

      debezium-connector-oracle   :  1.9.1 Final

      What is the connector configuration?

      apiVersion: kafka.strimzi.io/v1alpha1
      kind: KafkaConnector
      metadata:
        name: dbz-oracle-source-connector-XXXX
        labels:
          strimzi.io/cluster: dbz-oracle-source-connector-XXXX
      spec:
        class: io.debezium.connector.oracle.OracleConnector 
        tasksMax: 1
        config:
          database.url: jdbc:oracle:thin:@x.x.x.x:x:ServiceName
          database.user: 
          database.password: 
          database.dbname: SHEMA_NAME
          database.server.name: SEREVR_NAME
          snapshot.mode: initial
          snapshot.locking.mode: none
          schema.include.list: SHEMA_NAME
          table.include.list:xxxxx
          database.history.kafka.bootstrap.servers: kafka-server-bootstrap:9092
          database.history.kafka.topic: schema-changes.my_topic
          topic.creation.default.replication.factor: 3
          topic.creation.default.partitions: 3
          topic.creation.default.compression.type: lz4
          topic.creation.default.cleanup.policy: compact
          key.converter: io.confluent.connect.avro.AvroConverter
          key.converter.schema.registry.url: http://schema-registry:8081
          value.converter: io.confluent.connect.avro.AvroConverter
          transforms: unwrap
          transforms.unwrap.type: io.debezium.transforms.ExtractNewRecordState
          value.converter.schema.registry.url: http://schema-registry:8081
          decimal.handling.mode: string
          include.schema.changes: true

       

       

              blcksrx Hossein Torabi
              mohamed.icda Mohammed Mohammed (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Created:
                Updated: