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

Replace connectorName with kafkaTopicPrefix in kafka key/value schema

XMLWordPrintable

      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.

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

                Created:
                Updated:
                Resolved: