Skip to content

Tag: cassandra

How do I increase the default timeout in the Cassandra Java driver using the DriverConfigLoader?

Small question regarding a Spring Webflux Reactive Cassandra application please. On a setup Spring Boot 2.6.4 with Webflux and reactive Cassandra, I am using the app to insert some data in Cassandra tables. Things works fine, until when there is a higher load, I am seeing an issue (stack trace attached) The thing is, reading some documentation, I thought this

Asynchronous inserts to cassandra with save order of inserts per key

I have an ordered set of incoming events and I need to insert them into Cassandra. I want to take advantage of the speed of asynchronous inserts, but my incoming events may have duplicates by key of target table. If I understand correctly, then asynchronous insertions can’t guarantee data consistency in this case, since asynchronous executions imply the program order

why is my maven sub dependency version for spark connector package different from others

I am trying to use a pom file from a existing project and I am getting an error “Cannot resolve org.yaml:snakeyaml:1.15” What I find out about this error is that the com.datastax.spark:spark-cassandra-connector_2.11:2.5.0 uses a couple dependencies and a couple levels down it is using snakeyaml:1.15 which is quarantined by company proxy. Is there a way to specify for a given

I have declared primary using PartitionKey annotation but still getting Entity Order does not declare a primary key

I have the following POJO: Getting the exception at the following code: The definition of connectionManager is here: The exception is as: I am implementing by following the documentation here: . What could be the possible cause of this? EDIT:- Adding the schema definition: Answer Full Edit : There are a few things going on here which confuses

I am trying to write a DAO interface using Datastax 4.2.2, but getting several compile errors

I have the following POJO: And now I am writing the OrderDao as following: And when I do ./gradlew build I get the following errors: I am implementing by following the documentation here: . What could be the possible cause of this? Thanks. Answer You are missing the @Entity annotation on your Order class: