Custom Cassandra YAML and JVM options.

operator/params.yaml

@@ -766,3 +766,11 @@ parameters:
   - name: JVM_OPT_G1R_SET_UPDATING_PAUSE_TIME_PERCENT
     description: "Have the JVM do less remembered set work during STW, instead preferring concurrent GC. Reduces p99.9 latency."
     default: ""
+
+  - name: CUSTOM_CASSANDRA_YAML_BASE64
+    description: "Base64 encoded Cassandra properties appended to cassandra.yaml."
+    default: ""
+
+  - name: CUSTOM_JVM_OPTIONS_BASE64
+    description: "Base64 encoded JVM Options appended to jvm.options."
+    default: ""

operator/templates/cassandra-yaml.yaml

@@ -1352,3 +1352,7 @@ data:
     {{ if .Params.OTC_BACKLOG_EXPIRATION_INTERVAL_MS }}
     otc_backlog_expiration_interval_ms: {{ .Params.OTC_BACKLOG_EXPIRATION_INTERVAL_MS }}
     {{ end }}
+
+    {{ if .Params.CUSTOM_CASSANDRA_YAML_BASE64 }}
+    {{ .Params.CUSTOM_CASSANDRA_YAML_BASE64 | b64dec }}
+    {{ end }}

operator/templates/jvm-options.yaml

@@ -345,3 +345,7 @@ data:
     ### Cassandra 4.0 which will use JDK 11.
     -XX:+UnlockExperimentalVMOptions
     -XX:+UseCGroupMemoryLimitForHeap
+
+    {{ if .Params.CUSTOM_JVM_OPTIONS_BASE64 }}
+    {{ .Params.CUSTOM_JVM_OPTIONS_BASE64 | b64dec }}
+    {{ end }}

tests/suites/sanity_test.go

@@ -1,6 +1,7 @@
 package suites
 
 import (
+	"encoding/base64"
 	"fmt"
 	"os"
 	"strings"
@@ -85,6 +86,32 @@ var _ = Describe(TestName, func() {
 		Expect(configuration[parameter]).To(Equal(desiredValue))
 	})
 
+	It("Customize cassandra.yaml", func() {
+		parameter := "otc_backlog_expiration_interval_ms"
+		initialValue := "200"
+		desiredValue := "300"
+		desiredValueBase64 := base64.StdEncoding.EncodeToString([]byte("otc_backlog_expiration_interval_ms: 300"))
+
+		configuration, err := cassandra.ClusterConfiguration(
+			TestNamespace, TestInstance,
+		)
+		Expect(err).To(BeNil())
+		Expect(configuration[parameter]).To(Equal(initialValue))
+
+		err = kudo.UpdateInstanceParameters(
+			TestNamespace,
+			TestInstance,
+			map[string]string{"CUSTOM_CASSANDRA_YAML_BASE64": desiredValueBase64},
+		)
+		Expect(err).To(BeNil())
+
+		configuration, err = cassandra.ClusterConfiguration(
+			TestNamespace, TestInstance,
+		)
+		Expect(err).To(BeNil())
+		Expect(configuration[parameter]).To(Equal(desiredValue))
+	})
+
 	It("Uninstalls the operator", func() {
 		err := kudo.UninstallOperator(OperatorName, TestNamespace, TestInstance)
 		Expect(err).To(BeNil())