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

Replace connectorName with kafkaTopicPrefix in kafka key/value schema

    XMLWordPrintable

Details

    Description

      Replace the `connectorName` with `kafkaTopicPrefix` (which is actually the logical cluster name) in kafka key/value schema of cassandra-cdc, otherwise, agents deployed on different nodes will produce different kafka schemas for the same kafka topic and cause downstream processing to fail.

      Attachments

        Activity

          People

            zhou.bing@husky.neu.edu Bingqin Zhou
            zhou.bing@husky.neu.edu Bingqin Zhou
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: