【问题标题】:Required configs for spring kafkaspring kafka 所需的配置
【发布时间】:2022-12-26 00:52:48
【问题描述】:

spring Kafka 所需的配置是什么?

【问题讨论】:

    标签: java spring-boot apache-kafka spring-kafka apache-kafka-connect


    【解决方案1】:

    您需要在 application.yml 中为生产者和消费者添加属性以使其正常工作。

    spring:
      kafka:
        properties:
          security.protocol: SSL
          ssl:
            endpoint:
              identification:
                algorithm: ''
        consumer:
          value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
          key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
          bootstrap-servers: kafka-url:9093
          group-id: "group-id"
          auto-offset-reset: latest
          enable-auto-commit: true
          ssl:
            keystore-location: file:
            truststore-location: file:
            keystore-password: 
            truststore-password: 
    
        producer:
          bootstrap-servers: kafka-url:9093
          value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
          key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
          ssl:
            keystore-location: file:
            truststore-location: file:
            keystore-password: 
            truststore-password: 
    

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2019-07-14
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2021-08-02
      • 1970-01-01
      相关资源
      最近更新 更多