cdc-apache-cassandra
cdc-apache-cassandra copied to clipboard
datastax
Datastax CDC for Apache Cassandra
I try to install CDC for Cassandra . when I start cassandra with agent, I encountered some errors，as bellow: ``` ERROR [CdcCommitlogProcessor:1] 2023-03-28 13:08:55,296 CommitLogReaderService.java:282 - Task segment=1679972621190 completed=true syncPosition=0...
Today, the C* source connectors only allows 1:1 between tables and sinks. In order to increate the utilization of the underling resources associated with a single source instance (e.g. Memory...
I am using Cassandra 4 and cdc-apache-cassandra 2.2.3. Consider below table. ``` cqlsh:ks1> DESC foo_comp ; CREATE TABLE ks1.foo_comp ( a int, b text, c text, PRIMARY KEY (a, b)...
This performance improvement applies only to the JSON only format introduced here #79 #74 In AVRO and JSON Key Value schemas, the Key is populated based on the mutation key...
For logical types, the AVRO `schema.getLogicalType()` always returns null although the name of the logical type is populated. The NativeJsonConverter for now relies on the `schema.getName()` instead to select the...
It seems that cdcWorkingDir is not used by the C* 3 Agent. but it created at Agent startup. We can ignore that setting with the C*3 Agent and also add...
Let's say you create a table `table1` in this way `(key text, value text, primary key (text)) with cdc=true`. Then the agent will [cache the schema for the primary keys...
While the CDC agent publish mutations to the dirty topic in Pulsar, the deployed C* source needs to query back Cassandra nodes for the converged record before publishing to the...
``` PulsarSingleNodeDse4Tests > testInvalidSchema() FAILED java.lang.AssertionError: Expecting one message, check the agent log at org.junit.Assert.fail(Assert.java:89) at org.junit.Assert.assertTrue(Assert.java:42) at org.junit.Assert.assertNotNull(Assert.java:713) at com.datastax.oss.cdc.PulsarSingleNodeTests.testInvalidSchema(PulsarSingleNodeTests.java:432) ``` https://github.com/datastax/cdc-apache-cassandra/runs/6776506504?check_suite_focus=true