Nigel, Are you using something like this or rolled your own?
https://github.com/smartcat-labs/cassandra-kafka-connector/tree/master/cassandra-cdc Ive used it in a docker composition and it seemed to work fine for me. https://github.com/smartcat-labs/cassandra-kafka-connector/blob/master/cassandra-trigger/src/main/java/io/smartcat/cassandra/trigger/KafkaTrigger.java -- Rahul Singh rahul.si...@anant.us Anant Corporation On Feb 6, 2018, 5:50 AM -0500, Nigel LEACH <nigel.le...@uk.bnpparibas.com>, wrote: > Hello, I’m loading Cassandra (v3.10.0.1652) data into a Kafka (v1.0.0) topic > via CDC and the org.apache.cassandra.db.commitlog.CommitLogReader. All seems > to fit together, but I am seeing an “Invalid partitioner RandomPartitioner” > error thrown. Is CDC compatible with the RandomPartitioner? There doesn’t > seem to be a great deal of documentation, but I may well have missed > something. > > Many thanks for any assistance, before I start debugging in anger. > Nigel > > ___________________________________________________________ > This e-mail may contain confidential and/or privileged information. If you > are not the intended recipient (or have received this e-mail in error) please > notify the sender immediately and delete this e-mail. Any unauthorised > copying, disclosure or distribution of the material in this e-mail is > prohibited. > Please refer to http://www.bnpparibas.co.uk/en/email-disclaimer/ for > additional disclosures.
