CNDB-15667: CNDB-15623: Only use write path for CDC tables in CassandraStreamReceiver if CDC is enabled on the node (#2043)

[michaelsembwever]

https://github.com/riptano/cndb/issues/15667

Port into main-5.0 commit 8277624

CNDB-15667: CNDB-15623: Only use write path for CDC tables in CassandraStreamReceiver if CDC is enabled on the node (#2043)

Repairs use the local write path for streams on CDC-enabled tables, based on table schema. This interacts poorly with the separation of CNDB services.

This commit fixes the issue by only using the CDC write path for a stream if CDC is enabled in the node's configuration (as well as in the schema). This avoids attempting to use the local write path if commitlog-based CDC is not enabled.

[github-actions]

Checklist before you submit for review

• This PR adheres to the Definition of Done
• Make sure there is a PR in the CNDB project updating the Converged Cassandra version
• Use NoSpamLogger for log lines that may appear frequently in the logs
• Verify test results on Butler
• Test coverage for new/modified code is > 80%
• Proper code formatting
• Proper title for each commit staring with the project-issue number, like CNDB-1234
• Each commit has a meaningful description
• Each commit is not very long and contains related changes
• Renames, moves and reformatting are in distinct commits
• All new files should contain the DataStax copyright header instead of the Apache License one

[driftx]

CDC test failures look related

[michaelsembwever]

CDC test failures look related

should be fixed now. the debug logline had changed a little.

[sonarqubecloud]

Quality Gate passed

Issues
0 New issues
0 Accepted issues

Measures
0 Security Hotspots
100.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud

[cassci-bot]

❌ Build ds-cassandra-pr-gate/PR-2078 rejected by Butler

---

10 regressions found
See build details here

---

Found 10 new test failures

Test	Explanation	Runs	Upstream
o.a.c.cql3.validation.operations.AggregationQueriesTest.testAggregationQueryShouldNotTimeoutWhenItExceedesReadTimeout (compression)	REGRESSION	🔴🔴	2 / 13
o.a.c.distributed.test.BootstrapBinaryDisabledTest.test	REGRESSION	🔴🔵	0 / 13
o.a.c.distributed.test.RepairTest.testForcedNormalRepairWithOneNodeDown[nodesHaveCDC=true, tableHasCDC=true]	NEW	🔵🔴	0 / 13
o.a.c.distributed.test.RepairTest.testParallelRepairWithDefaultCompression[nodesHaveCDC=true, tableHasCDC=true]	NEW	🔵🔴	0 / 13
o.a.c.distributed.test.RepairTest.testParallelRepairWithMinCompressRatio[nodesHaveCDC=true, tableHasCDC=true]	NEW	🔵🔴	0 / 13
o.a.c.distributed.test.RepairTest.testParallelRepairWithoutCompression[nodesHaveCDC=true, tableHasCDC=true]	NEW	🔵🔴	0 / 13
o.a.c.distributed.test.RepairTest.testSequentialRepairWithDefaultCompression[nodesHaveCDC=true, tableHasCDC=true]	NEW	🔵🔴	0 / 13
o.a.c.distributed.test.RepairTest.testSequentialRepairWithMinCompressRatio[nodesHaveCDC=true, tableHasCDC=true]	NEW	🔵🔴	0 / 13
o.a.c.distributed.test.RepairTest.testSequentialRepairWithoutCompression[nodesHaveCDC=true, tableHasCDC=true]	NEW	🔵🔴	0 / 13
o.a.c.metrics.TrieMemtableMetricsTest.testContentionMetrics (compression)	REGRESSION	🔴🔴	4 / 13

---

Found 5 known test failures