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

Improve context sharing between openlineage core module and OpenLineage STM

XMLWordPrintable

    • Icon: Enhancement Enhancement
    • Resolution: Unresolved
    • Icon: Major Major
    • 3.4.0.Alpha1
    • None
    • core-library
    • None
    • False
    • Hide

      None

      Show
      None
    • False

      Given that the sharing is required to let the events emitted by the SMT have the same run id, the current implementation uses a static field approach. 

      This design is based on a strong assumption that the connector and the SMT are loaded by the same class loader. In KC 4.1 this could be not always true given the recent introduction of KIP-891: Running multiple versions of Connector plugins.

      The idea is to pass the runId in records header has did for `taskId`, `connectorLogicalName` and `connectorName`. 

              Unassigned Unassigned
              rh-ee-mvitale Mario Fiore Vitale
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated: