在 Spring Boot 配置 Kafka 安全认证 - VictorBu - 博客园 

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，账号密码认证

​

分类: Java

标签: Spring Boot, Kafka

好文要顶;) 关注我;) 收藏该文;) ; "分享至新浪微博") ; "分享至微信")

VictorBu
关注 - 14
粉丝 - 35

+加关注;)

0

0

« 上一篇： Java MQTT 客户端之 Paho
» 下一篇： 日志聚合工具之 Loki

原网址: 访问
创建于: 2021-11-04 11:15:31
目录: default
标签: 无

未标明原创文章均为采集，版权归作者所有，转载无需和我联系，请注明原出处，南摩阿彌陀佛，知识，不只知道，要得到

请先后发表评论
  • 最新评论
  • 总共0条评论