@@ -368,7 +368,11 @@ Return whether Redis uses password authentication or not
368
368
{ {- end } }
369
369
370
370
{ {- define " featbit.kafka.producer.auth.enabled" -} }
371
- { {- if and (not .Values.kafka.enabled) (or .Values.externalKafka.brokers.producer.password .Values.externalKafka.brokers.producer.existingSecret) -} }
371
+ { {- if .Values.kafka.enabled -} }
372
+ { {- if ne " PLAINTEXT" (upper .Values.kafka.listeners.client.protocol) -} }
373
+ { {- true -} }
374
+ { {- end -} }
375
+ { {- else if and (not .Values.kafka.enabled) (or .Values.externalKafka.brokers.producer.password .Values.externalKafka.brokers.producer.existingSecret) -} }
372
376
{ {- true -} }
373
377
{ {- end -} }
374
378
{ {- end -} }
@@ -380,23 +384,35 @@ Return whether Redis uses password authentication or not
380
384
{ {- end -} }
381
385
382
386
{ {- define " featbit.kafka.producer.secretName" -} }
383
- { {- if .Values.externalKafka.brokers.producer.existingSecret } }
387
+ { {- if .Values.kafka.enabled -} }
388
+ { {- if .Values.kafka.sasl.existingSecret -} }
389
+ { {- printf " %s" .Values.kafka.sasl.existingSecret -} }
390
+ { {- else -} }
391
+ { {- printf " %s-user-passwords" (include " featbit.kafka.fullname" .) -} }
392
+ { {- end -} }
393
+ { {- else if .Values.externalKafka.brokers.producer.existingSecret } }
384
394
{ {- printf " %s" .Values.externalKafka.brokers.producer.existingSecret -} }
385
395
{ {- else -} }
386
396
{ {- printf " %s-external-producer" (include " featbit.kafka.fullname" .) -} }
387
397
{ {- end -} }
388
398
{ {- end -} }
389
399
390
400
{ {- define " featbit.kafka.producer.secretPasswordKey" -} }
391
- { {- if and (not .Values.kafka.enabled) .Values.externalKafka.brokers.producer.existingSecret -} }
401
+ { {- if .Values.kafka.enabled -} }
402
+ { {- printf " client-passwords" -} }
403
+ { {- else if and (not .Values.kafka.enabled) .Values.externalKafka.brokers.producer.existingSecret -} }
392
404
{ {- required " You need to provide existingSecretPasswordKey when an existingSecret is specified in external kafka producer" .Values.externalKafka.brokers.producer.existingSecretPasswordKey | printf " %s" -} }
393
405
{ {- else -} }
394
406
{ {- printf " kafka-external-producer-password" -} }
395
407
{ {- end -} }
396
408
{ {- end -} }
397
409
398
410
{ {- define " featbit.kafka.consumer.auth.enabled" -} }
399
- { {- if and (not .Values.kafka.enabled) (or .Values.externalKafka.brokers.consumer.password .Values.externalKafka.brokers.consumer.existingSecret) -} }
411
+ { {- if .Values.kafka.enabled -} }
412
+ { {- if ne " PLAINTEXT" (upper .Values.kafka.listeners.client.protocol) -} }
413
+ { {- true -} }
414
+ { {- end -} }
415
+ { {- else if and (not .Values.kafka.enabled) (or .Values.externalKafka.brokers.consumer.password .Values.externalKafka.brokers.consumer.existingSecret) -} }
400
416
{ {- true -} }
401
417
{ {- end -} }
402
418
{ {- end -} }
@@ -408,21 +424,77 @@ Return whether Redis uses password authentication or not
408
424
{ {- end -} }
409
425
410
426
{ {- define " featbit.kafka.consumer.secretName" -} }
411
- { {- if .Values.externalKafka.brokers.consumer.existingSecret } }
427
+ { {- if .Values.kafka.enabled -} }
428
+ { {- if .Values.kafka.sasl.existingSecret -} }
429
+ { {- printf " %s" .Values.kafka.sasl.existingSecret -} }
430
+ { {- else -} }
431
+ { {- printf " %s-user-passwords" (include " featbit.kafka.fullname" .) -} }
432
+ { {- end -} }
433
+ { {- else if .Values.externalKafka.brokers.consumer.existingSecret } }
412
434
{ {- printf " %s" .Values.externalKafka.brokers.consumer.existingSecret -} }
413
435
{ {- else -} }
414
436
{ {- printf " %s-external-consumer" (include " featbit.kafka.fullname" .) -} }
415
437
{ {- end -} }
416
438
{ {- end -} }
417
439
418
440
{ {- define " featbit.kafka.consumer.secretPasswordKey" -} }
419
- { {- if and (not .Values.kafka.enabled) .Values.externalKafka.brokers.consumer.existingSecret -} }
441
+ { {- if .Values.kafka.enabled -} }
442
+ { {- printf " client-passwords" -} }
443
+ { {- else if and (not .Values.kafka.enabled) .Values.externalKafka.brokers.consumer.existingSecret -} }
420
444
{ {- required " You need to provide existingSecretPasswordKey when an existingSecret is specified in external kafka consumer" .Values.externalKafka.brokers.consumer.existingSecretPasswordKey | printf " %s" -} }
421
445
{ {- else -} }
422
446
{ {- printf " kafka-external-consumer-password" -} }
423
447
{ {- end -} }
424
448
{ {- end -} }
425
449
450
+ { {- define " featbit.kafka.producer.user" -} }
451
+ { {- if .Values.kafka.enabled -} }
452
+ { {- printf " %s" (first .Values.kafka.sasl.client.users) -} }
453
+ { {- else -} }
454
+ { {- printf " %s" .Values.externalKafka.brokers.producer.user -} }
455
+ { {- end -} }
456
+ { {- end -} }
457
+
458
+ { {- define " featbit.kafka.consumer.user" -} }
459
+ { {- if .Values.kafka.enabled -} }
460
+ { {- printf " %s" (first .Values.kafka.sasl.client.users) -} }
461
+ { {- else -} }
462
+ { {- printf " %s" .Values.externalKafka.brokers.consumer.user -} }
463
+ { {- end -} }
464
+ { {- end -} }
465
+
466
+ { {- define " featbit.kafka.producer.protocol" -} }
467
+ { {- if .Values.kafka.enabled -} }
468
+ { {- printf " %s" (.Values.kafka.listeners.client.protocol) -} }
469
+ { {- else -} }
470
+ { {- printf " %s" .Values.externalKafka.brokers.producer.protocol -} }
471
+ { {- end -} }
472
+ { {- end -} }
473
+
474
+ { {- define " featbit.kafka.consumer.protocol" -} }
475
+ { {- if .Values.kafka.enabled -} }
476
+ { {- printf " %s" (.Values.kafka.listeners.client.protocol) -} }
477
+ { {- else -} }
478
+ { {- printf " %s" .Values.externalKafka.brokers.consumer.protocol -} }
479
+ { {- end -} }
480
+ { {- end -} }
481
+
482
+ { {- define " featbit.kafka.producer.mechanism" -} }
483
+ { {- if .Values.kafka.enabled -} }
484
+ { {- printf " PLAIN" -} }
485
+ { {- else -} }
486
+ { {- printf " %s" .Values.externalKafka.brokers.producer.mechanism -} }
487
+ { {- end -} }
488
+ { {- end -} }
489
+
490
+ { {- define " featbit.kafka.consumer.mechanism" -} }
491
+ { {- if .Values.kafka.enabled -} }
492
+ { {- printf " PLAIN" -} }
493
+ { {- else -} }
494
+ { {- printf " %s" .Values.externalKafka.brokers.consumer.mechanism -} }
495
+ { {- end -} }
496
+ { {- end -} }
497
+
426
498
{ *
427
499
------ CLICKHOUSE ------
428
500
*}
0 commit comments