版本:

        spring-boot:1.5.13.RELEASE

        kafka-client:2.4.1

yml配置:

kafka:
    # kafka集群地址
    bootstrap-servers: ip:1,ip2:2
    # KafkaProperties中的porprites属性,网上看的案例properties都配置再consumer和producer下,
    # 这里不行,可能是版本问题,这里的properties参数和consumer平级
    properties:
      sasl.mechanism: SCRAM-SHA-256
      security.protocol: SASL_PLAINTEXT
      #注意结尾的; 必填,不填;报错  name  和  password替换成你自己kafka配置的账号密码
      sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="name" password="password";
    consumer:
      enable-auto-commit: true
      session-timeout: 6000
      auto-commit-interval: 1000
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      autoOffsetReset: latest
      concurrency: 20
      topic: mytopic5
      groupId: canal-test-group
    producer:
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

参考:

下述连接存在问题properties在consumer下面,我这里是和consumer平级
wSpringBoot 支持Kafka安全认证 SASL/PLAINTEXT,账号密码认证_leo_KING999的博客-CSDN博客  环境操作系统:CentOS 7.3Kafka Version:2.12Zookeeper Version:3.6.1一、Zookeeper集群配置SASLzookeeper所有节点都是对等的,只是各个节点角色可能不相同。以下步骤所有的节点配置相同。1、zoo.cfg文件配置为zookeeper添加SASL支持,在配置文件zoo.cfg添加authProvider.1=org.apache.zookeeper.server.auth.SASLAuthenticat.https://blog.csdn.net/u010637366/article/details/108142216?utm_medium=distribute.pc_relevant.none-task-blog-2~default~baidujs_baidulandingword~default-0-108142216-blog-123543746.pc_relevant_scanpaymentv1&spm=1001.2101.3001.4242.1&utm_relevant_index=3

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐