diff --git a/cassandra-kubernetes/README.adoc b/cassandra-kubernetes/README.adoc index 1e8ca261d..9db2826ae 100644 --- a/cassandra-kubernetes/README.adoc +++ b/cassandra-kubernetes/README.adoc @@ -47,7 +47,7 @@ cassandra-1 1/1 Running 0 2h You can also verify the health of your cluster by running ---- -$ kubectl exec -it nodetool status +$ kubectl exec -- nodetool status Datacenter: DC1-K8Demo ====================== Status=Up/Down diff --git a/cassandra-kubernetes/pom.xml b/cassandra-kubernetes/pom.xml index d2f149b69..83b70f559 100644 --- a/cassandra-kubernetes/pom.xml +++ b/cassandra-kubernetes/pom.xml @@ -35,7 +35,7 @@ Database - 4.0.0 + 4.19.2 org.apache.camel.spring.Main @@ -74,8 +74,8 @@ - com.datastax.cassandra - cassandra-driver-core + org.apache.cassandra + java-driver-core ${cassandra.driver.version} diff --git a/cassandra-kubernetes/src/main/java/org/apache/camel/example/kubernetes/jkube/CqlPopulateBean.java b/cassandra-kubernetes/src/main/java/org/apache/camel/example/kubernetes/jkube/CqlPopulateBean.java index 2e5a7668d..92e3e25e6 100644 --- a/cassandra-kubernetes/src/main/java/org/apache/camel/example/kubernetes/jkube/CqlPopulateBean.java +++ b/cassandra-kubernetes/src/main/java/org/apache/camel/example/kubernetes/jkube/CqlPopulateBean.java @@ -16,8 +16,7 @@ */ package org.apache.camel.example.kubernetes.jkube; -import com.datastax.driver.core.Cluster; -import com.datastax.driver.core.Session; +import com.datastax.oss.driver.api.core.CqlSession; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -26,8 +25,7 @@ public class CqlPopulateBean { private static final Logger log = LoggerFactory.getLogger(CqlPopulateBean.class); public void populate() { - try (Cluster cluster = Cluster.builder().addContactPoint("cassandra").build(); - Session session = cluster.connect()) { + try (CqlSession session = CqlSession.builder()/*.addContactEndPoint("cassandra")*/.build();) { session.execute("CREATE KEYSPACE IF NOT EXISTS test WITH REPLICATION = {'class':'SimpleStrategy', 'replication_factor':1};"); session.execute("CREATE TABLE IF NOT EXISTS test.users ( id int primary key, name text );"); session.execute("INSERT INTO test.users (id,name) VALUES (1, 'oscerd') IF NOT EXISTS;");