Add Affinity field for Cruise Control in KafkaCluster resource(#962)

* Adding Affinity for Cruise Control * removing pkg/sdk * Adding api changes for tag
banzaicloud · Apr 24, 2023 · c94e166 · c94e166
1 parent ce1be1f
commit c94e166
Show file tree

Hide file tree

Showing 4 changed files with 1,752 additions and 0 deletions.
diff --git a/api/v1beta1/kafkacluster_types.go b/api/v1beta1/kafkacluster_types.go
@@ -267,6 +267,7 @@ type CruiseControlConfig struct {
 	Log4jConfig                string                        `json:"log4jConfig,omitempty"`
 	Image                      string                        `json:"image,omitempty"`
 	TopicConfig                *TopicConfig                  `json:"topicConfig,omitempty"`
+	Affinity                   *corev1.Affinity              `json:"affinity,omitempty"`
 	//  Annotations to be applied to CruiseControl pod
 	// +optional
 	CruiseControlAnnotations map[string]string `json:"cruiseControlAnnotations,omitempty"`
@@ -839,6 +840,11 @@ func (cConfig *CruiseControlConfig) GetNodeSelector() map[string]string {
 	return cConfig.NodeSelector
 }
 
+// GetAffinity returns the Affinity config for cruise control
+func (cConfig *CruiseControlConfig) GetAffinity() *corev1.Affinity {
+	return cConfig.Affinity
+}
+
 // GetNodeSelector returns the node selector for envoy
 func (eConfig *EnvoyConfig) GetNodeSelector() map[string]string {
 	return eConfig.NodeSelector

diff --git a/api/v1beta1/zz_generated.deepcopy.go b/api/v1beta1/zz_generated.deepcopy.go