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

OlrNetworkClient does not disconnect when error occurs

XMLWordPrintable

      Bug report

      For bug reports, provide this information, please:

      What Debezium connector do you use and what version?

      debezium-connector-oracle version 2.6.1.Final

      What is the connector configuration?

      {
        "name": "source-data-types-olr-connector",
        "config": {
          "connector.class": "io.debezium.connector.oracle.OracleConnector",
          "tasks.max": "1",
          "database.hostname": "oracle",
          "database.port": "1521",
          "database.user": "c##dbzuser",
          "database.password": "dbz",
          "database.dbname": "orclcdb",
          "database.pdb.name": "orclpdb1",
          "database.connection.adapter": "olr",
          "openlogreplicator.source": "ORACLE",
          "openlogreplicator.host": "olr",
          "openlogreplicator.port": "9000",
          "topic.prefix": "olr",
          "lob.enabled": "true",
          "schema.name.adjustment.mode": "avro",
          "table.include.list": "C##DBZUSER.SOURCE_DATA_TYPES",
          "include.schema.changes": "false",
          "schema.history.internal.kafka.bootstrap.servers" : "kafka:9092",
          "schema.history.internal.kafka.topic": "schema-changes.data-types-olr",
          "heartbeat.interval.ms": "60000",
          "custom.metric.tags": "connector=source-data-types-connector",
          "key.converter": "io.confluent.connect.avro.AvroConverter",
          "key.converter.schema.registry.url": "http://schema-registry:8081",
          "value.converter": "io.confluent.connect.avro.AvroConverter",
          "value.converter.schema.registry.url": "http://schema-registry:8081"
        }
      }
      

      What is the captured database version and mode of deployment?

      Oracle Database 19, Docker

      What behaviour do you expect?

      OlrNetworkClient will disconnect if an unexpected error occurs while reading events from OpenLogReplicator.

      <Your answer>

      What behaviour do you see?

      I made a mistake in configuration OpenLogReplicator.json when setting up OpenLogReplicator. After that Oracle connector crashed with the following error:

      Caused by: java.lang.NullPointerException
      at io.debezium.connector.oracle.olr.client.OlrNetworkClient.readNextEventWithStartScnSkip(OlrNetworkClient.java:147)
      at io.debezium.connector.oracle.olr.client.OlrNetworkClient.readEvent(OlrNetworkClient.java:126)
      at io.debezium.connector.oracle.olr.OpenLogReplicatorStreamingChangeEventSource.execute(OpenLogReplicatorStreamingChangeEventSource.java:119) ... 9 more
      

      and OlrNetworkClient did not disconnect.

      Do you see the same behaviour using the latest relesead Debezium version?

      Yes

      Feature request or enhancement

      https://github.com/debezium/debezium/pull/5605

            Unassigned Unassigned
            andrey.pustovetov@gmail.com Andrey Pustovetov
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Created:
              Updated:
              Resolved: