@@ -287,6 +287,15 @@ func (s *strimziProvider) configureKafkaCluster() error {
287
287
kafLimits = * s .Env .Spec .Providers .Kafka .Cluster .Resources .Limits
288
288
}
289
289
290
+ var klabels apiextensions.JSON
291
+
292
+ err = klabels .UnmarshalJSON ([]byte (`{
293
+ "service" : "strimziKafka"
294
+ }` ))
295
+ if err != nil {
296
+ return fmt .Errorf ("could not unmarshal klabels: %w" , err )
297
+ }
298
+
290
299
k .Spec = & strimzi.KafkaSpec {
291
300
Kafka : strimzi.KafkaSpecKafka {
292
301
Config : & kafConfig ,
@@ -296,15 +305,46 @@ func (s *strimziProvider) configureKafkaCluster() error {
296
305
Requests : & kafRequests ,
297
306
Limits : & kafLimits ,
298
307
},
308
+ Template : & strimzi.KafkaSpecKafkaTemplate {
309
+ PerPodService : & strimzi.KafkaSpecKafkaTemplatePerPodService {
310
+ Metadata : & strimzi.KafkaSpecKafkaTemplatePerPodServiceMetadata {
311
+ Labels : & klabels ,
312
+ },
313
+ },
314
+ Pod : & strimzi.KafkaSpecKafkaTemplatePod {
315
+ Metadata : & strimzi.KafkaSpecKafkaTemplatePodMetadata {
316
+ Labels : & klabels ,
317
+ },
318
+ },
319
+ },
299
320
},
300
321
Zookeeper : strimzi.KafkaSpecZookeeper {
301
322
Replicas : replicas ,
302
323
Resources : & strimzi.KafkaSpecZookeeperResources {
303
324
Requests : & zRequests ,
304
325
Limits : & zLimits ,
305
326
},
327
+ Template : & strimzi.KafkaSpecZookeeperTemplate {
328
+ NodesService : & strimzi.KafkaSpecZookeeperTemplateNodesService {
329
+ Metadata : & strimzi.KafkaSpecZookeeperTemplateNodesServiceMetadata {
330
+ Labels : & klabels ,
331
+ },
332
+ },
333
+ Pod : & strimzi.KafkaSpecZookeeperTemplatePod {
334
+ Metadata : & strimzi.KafkaSpecZookeeperTemplatePodMetadata {
335
+ Labels : & klabels ,
336
+ },
337
+ },
338
+ },
306
339
},
307
340
EntityOperator : & strimzi.KafkaSpecEntityOperator {
341
+ Template : & strimzi.KafkaSpecEntityOperatorTemplate {
342
+ Pod : & strimzi.KafkaSpecEntityOperatorTemplatePod {
343
+ Metadata : & strimzi.KafkaSpecEntityOperatorTemplatePodMetadata {
344
+ Labels : & klabels ,
345
+ },
346
+ },
347
+ },
308
348
TopicOperator : & strimzi.KafkaSpecEntityOperatorTopicOperator {
309
349
Resources : & strimzi.KafkaSpecEntityOperatorTopicOperatorResources {
310
350
Requests : & entityTopicRequests ,
0 commit comments