spring:
  kafka:
    bootstrap-servers: localhost:9092
    template:
      default-topic: topic
    producer:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer
    consumer:
      group-id: 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
    properties:
      security:
        protocol: SASL_PLAINTEXT
      sasl:
        mechanism: SCRAM-SHA-256
        jaas:
          config: 'org.apache.kafka.common.security.scram.ScramLoginModule required username="username" password="password";'  

 

相关文章:

  • 2022-12-23
  • 2021-06-04
  • 2021-04-08
  • 2021-11-23
  • 2021-12-31
  • 2021-06-04
猜你喜欢
  • 2022-12-23
  • 2021-09-26
  • 2022-12-23
  • 2021-06-09
  • 2021-06-04
  • 2021-11-27
  • 2022-12-23
相关资源
相似解决方案