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

Make Cassandra Connector work with CommitLogTransfer better

XMLWordPrintable

      In order to make Cassandra Connector work (better) with customized CommitLogTransfer, the following improvements/fixes are still needed:

      • Fix commitLogTransferConfigs() in CassandraConnectorConfig.java  (Remove "commit.log.transfer" prefix from resulted config properties)
      • Use AbstractDirectoryWatcher to detect new files in relocation directory in CommitLogPostProcessor.java
      • Download error commitLogFiles only upon Cassandra CDC is started in CommitLogProcess.java
      • Improve loggings in deleteCommitLog() in CommitLogUtil.java (Log file path instead of file name)

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

              Created:
              Updated:
              Resolved: