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

Embedded engine fails to receive events from mongodb withnon-default port

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 1.4.0.Beta1
    • 1.4.0.Beta1
    • mongodb-connector
    • None
    • False
    • False
    • Undefined

      I'm preparing came-quarkus extension for camel-debezium-mongodb.

      I need to use version 1.4.0 of debezium connector because of DBZ-2138.

      I tried to prepare some integration tests using current 1.4.0-SNAPSHOT version and I discovered a problem.

      I've created reproducer - https://github.com/JiriOndrusek/debezium-reproducer-port , which contains description in README.md

      Briefly:
      Test works with connector 1.3.0 and mongo db running on port 30001
      Test fails with connector 1.4.0-SNAPSHOT and mongo db running on port 30001
      Test works with connector 1.4.0-SNAPSHOT and mongo db running on port 27017

      Therefor it seems, like there is a problem with using embedded engine with mongodb on non-default port.

      Here is a snippet from the log from the reproducer (failing scenario)

      2020-12-07 11:48:56,617 [127.0.0.1:30001] INFO connection - Opened connection [connectionId

      Unknown macro: {localValue}

      ] to 127.0.0.1:30001
      2020-12-07 11:48:56,617 [rce-coordinator] INFO cluster - Cluster description not yet available. Waiting for 30000 ms before timing out
      2020-12-07 11:48:56,617 [127.0.0.1:30001] INFO cluster - Monitor thread successfully connected to server with description ServerDescription{address=127.0.0.1:30001, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=9, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=5150965, setName='my-mongo-set', canonicalAddress=172.17.0.2:27017, hosts=[172.17.0.2:27017], passives=[], arbiters=[], primary='172.17.0.2:27017', tagSet=TagSet

      Unknown macro: {[]}

      , electionId=7fffffff0000000000000001, setVersion=1, topologyVersion=TopologyVersion

      Unknown macro: {processId=5fce0763208f858e1a67587e, counter=6}

      , lastWriteDate=Mon Dec 07 11:48:56 CET 2020, lastUpdateTimeNanos=12520592334800}

      I've noticed that connection is opened to `127.0.0.1:30001`, which is correct. But then I see `canonicalAddress=172.17.0.2:27017, hosts=[172.17.0.2:27017]` which seems wrong.

              rk3rn3r René Kerner
              jondruse@redhat.com Jiri Ondrusek
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Created:
                Updated:
                Resolved: