Generating a unique clientIdPrefix in KafkaListener

spring-boot kubernetes spring-kafka

Set kafka consumer client.id properties for change consumer client namehttps://docs.confluent.io/platform/current/installation/configuration/consumer-configs.html#consumerconfigs_client.id.

You can give property in yml file like below.

spring:  kafka:    consumer:      properties:        client.id: ${KAFKA_CLIENT_ID:unique-kafka-client-name}

for create unique value for client id you can use pod infohttps://kubernetes.io/docs/tasks/inject-data-application/environment-variable-expose-pod-information/#use-pod-fields-as-values-for-environment-variables

i.e metadata.uid

  env:    - name: KAFKA_CLIENT_ID      valueFrom:        fieldRef:          fieldPath: metadata.uid