removed redundant parameter

Author: adwk67

rust/operator-binary/src/controller.rs

@@ -433,9 +433,8 @@ pub async fn reconcile_kafka(
         }
     }
 
-    let discovery_cm =
-        build_discovery_configmap(kafka, kafka, validated_cluster, &bootstrap_listeners)
-            .context(BuildDiscoveryConfigSnafu)?;
+    let discovery_cm = build_discovery_configmap(kafka, validated_cluster, &bootstrap_listeners)
+        .context(BuildDiscoveryConfigSnafu)?;
 
     cluster_resources
         .add(client, discovery_cm)

rust/operator-binary/src/controller/build/config_map.rs

@@ -69,7 +69,6 @@ pub enum Error {
 }
 
 /// The rolegroup [`ConfigMap`] configures the rolegroup based on the configuration given by the administrator
-#[allow(clippy::too_many_arguments)]
 pub fn build_rolegroup_config_map(
     kafka: &v1alpha1::KafkaCluster,
     validated_cluster: &ValidatedKafkaCluster,

rust/operator-binary/src/discovery.rs

@@ -5,7 +5,7 @@ use stackable_operator::{
     builder::{configmap::ConfigMapBuilder, meta::ObjectMetaBuilder},
     crd::listener,
     k8s_openapi::api::core::v1::ConfigMap,
-    kube::{Resource, ResourceExt, runtime::reflector::ObjectRef},
+    kube::{ResourceExt, runtime::reflector::ObjectRef},
 };
 
 use crate::{
@@ -45,8 +45,7 @@ pub enum Error {
 /// Build a discovery [`ConfigMap`] containing information about how to connect to a certain
 /// [`v1alpha1::KafkaCluster`].
 pub fn build_discovery_configmap(
-    kafka: &v1alpha1::KafkaCluster,
-    owner: &impl Resource<DynamicType = ()>,
+    owner: &v1alpha1::KafkaCluster,
     validated_cluster: ValidatedKafkaCluster,
     listeners: &[listener::v1alpha1::Listener],
 ) -> Result<ConfigMap, Error> {
@@ -69,14 +68,14 @@ pub fn build_discovery_configmap(
     ConfigMapBuilder::new()
         .metadata(
             ObjectMetaBuilder::new()
-                .name_and_namespace(kafka)
+                .name_and_namespace(owner)
                 .name(owner.name_unchecked())
                 .ownerreference_from_resource(owner, None, Some(true))
                 .with_context(|_| ObjectMissingMetadataForOwnerRefSnafu {
-                    kafka: ObjectRef::from_obj(kafka),
+                    kafka: ObjectRef::from_obj(owner),
                 })?
                 .with_recommended_labels(&build_recommended_labels(
-                    kafka,
+                    owner,
                     KAFKA_CONTROLLER_NAME,
                     &resolved_product_image.product_version,
                     &KafkaRole::Broker.to_string(),

rust/operator-binary/src/resource/statefulset.rs

@@ -160,7 +160,6 @@ pub enum Error {
 ///
 /// The [`Pod`](`stackable_operator::k8s_openapi::api::core::v1::Pod`)s are accessible through the corresponding
 /// [`Service`](`stackable_operator::k8s_openapi::api::core::v1::Service`) from [`build_rolegroup_service`](`crate::resource::service::build_rolegroup_headless_service`).
-#[allow(clippy::too_many_arguments)]
 pub fn build_broker_rolegroup_statefulset(
     kafka: &v1alpha1::KafkaCluster,
     kafka_role: &KafkaRole,
@@ -570,7 +569,6 @@ pub fn build_broker_rolegroup_statefulset(
 }
 
 /// The controller rolegroup [`StatefulSet`] runs the rolegroup, as configured by the administrator.
-#[allow(clippy::too_many_arguments)]
 pub fn build_controller_rolegroup_statefulset(
     kafka: &v1alpha1::KafkaCluster,
     kafka_role: &KafkaRole,