From 77c11e165203efe0ca1b05f221d5ce47acfe2f7f Mon Sep 17 00:00:00 2001 From: obaydullahmhs Date: Wed, 17 Jan 2024 17:20:04 +0600 Subject: [PATCH] Add Kafka connect default resource Signed-off-by: obaydullahmhs --- apis/kafka/v1alpha1/connect_cluster_helpers.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/apis/kafka/v1alpha1/connect_cluster_helpers.go b/apis/kafka/v1alpha1/connect_cluster_helpers.go index 71159224e7..72db16090f 100644 --- a/apis/kafka/v1alpha1/connect_cluster_helpers.go +++ b/apis/kafka/v1alpha1/connect_cluster_helpers.go @@ -22,6 +22,7 @@ import ( "path/filepath" "strings" + "kubedb.dev/apimachinery/apis" catalog "kubedb.dev/apimachinery/apis/catalog/v1alpha1" "kubedb.dev/apimachinery/apis/kafka" api "kubedb.dev/apimachinery/apis/kubedb/v1alpha2" @@ -246,6 +247,11 @@ func (k *ConnectCluster) SetDefaults() { k.setDefaultContainerSecurityContext(&kfVersion, &k.Spec.PodTemplate) k.setDefaultInitContainerSecurityContext(&k.Spec.PodTemplate) + dbContainer := coreutil.GetContainerByName(k.Spec.PodTemplate.Spec.Containers, ConnectClusterContainerName) + if dbContainer != nil { + apis.SetDefaultResourceLimits(&dbContainer.Resources, api.DefaultResources) + } + k.Spec.Monitor.SetDefaults() if k.Spec.Monitor != nil && k.Spec.Monitor.Prometheus != nil && k.Spec.Monitor.Prometheus.Exporter.SecurityContext.RunAsUser == nil { k.Spec.Monitor.Prometheus.Exporter.SecurityContext.RunAsUser = kfVersion.Spec.SecurityContext.RunAsUser