JZTXT

kafka配置-yml篇

发布时间 2023-11-08 10:14:13作者: XSWClevo
spring:
  kafka:
    template:
      # 当使用 kafkaTemplate 的 sendDefault 方法的时候，使用的是这里配置的 topic
      defaultTopic: topic-1
    # partition-num 和 replication-num KafkaProperties 没有提供配置的地方
    bootstrap-servers: 127.0.0.1:9092
    producer:
      retries: 3
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer
    consumer:
      # @KafkaListener 中不指定 group-id 使用这边 groupId，这边也不指定项目就报错起不来，指定了就覆盖这边的
      # group-id: test
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      # 消息读取方式
      auto-offset-reset: latest
      # auto-offset-reset: earliest
      # 手动提交
      enable-auto-commit: false