I have a requirement of streaming cassandra 3.10 data updates in tables to aws msk. Basically I have couple of tables on which I would be setting up cdc=true. So if any insert/update etc. operation performed on these tables should stream to kafka (aws msk) topic.
I followed some online documentation. It suggests to use CassandraSourceConnector packed in com.datastax.oss.kafka.source.CassandraSourceConnector, but somehow I’m not able to find jar which contains above java class. Searched maven repo, datastax repo, datastax github project. Couldn’t find it at all.
Can someone suggest where do I get this?
Note- We have successfully created aws msk cluster. Now want to use msk plugin to create a connector.
This connector used to reside in the datastax/cdc-apache-cassandra GitHub repo but was removed in 2021 in this commit.
Right @dtroiano. I checked its git repo and couldn’t find that required source connector. Thanks for sharing this info.
So does this mean that this solution is no longer supported by DataStax? Any alternate to this?
I think I can also go with Debezium cdc solution which I’m yet to explore.
Yeah, Debezium comes to mind, or I see native Kafka CDC integration coming with CEP-44: Kafka integration for Cassandra CDC using Sidecar. CEP-44 looks to be for Cassandra 4, though, so it looks like you’d need to upgrade in order to use it (related JIRA here, Meetup YouTube about it).