在 Spring Boot 配置 Kafka 安全認證

spring:
  kafka:
    bootstrap-servers: IP:端口
    listener:
      missing-topics-fatal: false
    properties:
      sasl:
        mechanism: PLAIN
        jaas:
          config: 'org.apache.kafka.common.security.plain.PlainLoginModule required username="用戶名" password="密碼";'
      security:
        protocol: SASL_PLAINTEXT
    producer:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer
    consumer:
      group-id: test_consumer_group
      enable-auto-commit: true
      auto-commit-interval: 1000
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

參考：SpringBoot 支持Kafka安全認證 SASL/PLAINTEXT，賬號密碼認證

​