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

Make Cassandra Connector work with CommitLogTransfer better

    XMLWordPrintable

    Details

      Description

      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)

        Attachments

          Issue Links

            Activity

              People

              Assignee:
              Unassigned Unassigned
              Reporter:
              bingqinzhou Bingqin Zhou
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Dates

                Created:
                Updated:
                Resolved: