From 52917e0908da201f7c2e749aafab991315d38670 Mon Sep 17 00:00:00 2001 From: David Suarez <1847875+dave92082@users.noreply.github.com> Date: Thu, 4 Jan 2024 11:09:59 -0800 Subject: [PATCH] Set consistency prior to calling CreateSesion (#24649) * Set consistency prior to calling CreateSesion * Add changelog --------- Co-authored-by: Violet Hynes --- changelog/24649.txt | 3 +++ physical/cassandra/cassandra.go | 1 + 2 files changed, 4 insertions(+) create mode 100644 changelog/24649.txt diff --git a/changelog/24649.txt b/changelog/24649.txt new file mode 100644 index 0000000000..2e0161e20d --- /dev/null +++ b/changelog/24649.txt @@ -0,0 +1,3 @@ +```release-note:bug +cassandra: Update Cassandra to set consistency prior to calling CreateSession, ensuring consistency setting is correct when opening connection. +``` diff --git a/physical/cassandra/cassandra.go b/physical/cassandra/cassandra.go index 1c592ee33a..a7f22c468d 100644 --- a/physical/cassandra/cassandra.go +++ b/physical/cassandra/cassandra.go @@ -104,6 +104,7 @@ func NewCassandraBackend(conf map[string]string, logger log.Logger) (physical.Ba cluster := gocql.NewCluster(hosts...) cluster.Port = port cluster.Keyspace = keyspace + cluster.Consistency = consistency if retryCountStr, ok := conf["simple_retry_policy_retries"]; ok { retryCount, err := strconv.Atoi(retryCountStr)