diff --git a/apis/kubedb/v1alpha2/constants.go b/apis/kubedb/v1alpha2/constants.go index 5f057c56dd..b88577ab09 100644 --- a/apis/kubedb/v1alpha2/constants.go +++ b/apis/kubedb/v1alpha2/constants.go @@ -621,7 +621,6 @@ const ( KafkaTransactionSateLogMinISR = "transaction.state.log.min.isr" KafkaLogCleanerMinLagSec = "log.cleaner.min.compaction.lag.ms" KafkaLogCleanerBackoffMS = "log.cleaner.backoff.ms" - KafkaListenerNameRackRaft = "listener.name.internal.rack-raft.enabled" KafkaCCKubernetesMode = "cruise.control.metrics.reporter.kubernetes.mode" KafkaCCBootstrapServers = "cruise.control.metrics.reporter.bootstrap.servers" diff --git a/apis/kubedb/v1alpha2/kafka_webhook.go b/apis/kubedb/v1alpha2/kafka_webhook.go index 9221dbe6ae..af05f17089 100644 --- a/apis/kubedb/v1alpha2/kafka_webhook.go +++ b/apis/kubedb/v1alpha2/kafka_webhook.go @@ -193,6 +193,8 @@ var availableVersions = []string{ "3.3.0", "3.3.2", "3.4.0", + "3.4.1", + "3.5.1", } func validateVersion(db *Kafka) error {