application-dev.yml 2.26 KB
spring:
  datasource:
    url: jdbc:oracle:thin:@192.168.1.250:1521:orcl
    username: iclearimp
    password: iclearimp
    driver-class-name: oracle.jdbc.OracleDriver
  profiles:
    #系统环境
    env: dev
  #============== kafka ===================
  kafka:
    # 指定kafka server的地址,集群配多个,中间,逗号隔开
    bootstrap-servers: 47.103.140.98:9092
    #验证文件地址
    iclear-kerberos-jaasPath: /opt/fedex/iclearConnect/conf/app_3537251_iclear_jaas.conf
    iclear-kerberos-krb5: /opt/fedex/iclearConnect/conf/krb5.conf
    #=============== provider  =======================
    producer:
      #可以设置的值为:all, -1, 0, 1
      acks: -1
      # 当retris为0时,produce不会重复。retirs重发,此时repli节点完全成为leader节点,不会产生消息丢失。
      retries: 3
      # 每次批量发送消息的数量,produce积累到一定数据,一次发送
      batch-size: 323840
      properties:
        linger:
          # 如果kafka迟迟不发送消息(这里指的是消息没堆积到指定数量),那么过了这个时间(单位:毫秒)开始发送
          ms: 10
        max:
          block:
            # 控制block的时长,当buffer空间不够或者metadata丢失时产生block
            ms: 3000
      # produce积累数据一次发送,缓存大小达到buffer.memory就发送数据
      buffer-memory: 33554432
    #=============== consumer  =======================
    consumer:
      #topic-name
      topic-name: fdx.apac.cn.shipment.import.cdm.iclear
      # 指定默认消费者group id --> 由于在kafka中,同一组中的consumer不会读取到同一个消息,依靠groud.id设置组名
      group-id: imp-exp-tw-dev
      # smallest和largest才有效,如果smallest重新0开始读取,如果是largest从logfile的offset读取。一般情况下我们都是设置smallest
      auto-offset-reset: earliest
      # enable.auto.commit:true --> 设置自动提交offset
      enable-auto-commit: false
      #如果'enable.auto.commit'为true,则消费者偏移自动提交给Kafka的频率(以毫秒为单位),默认值为5000。
      auto-commit-interval: 1000
      #每次kafka消费量
      max-poll-records: 1000
      #kafka消费线程数
      spring-kafka-threadNum: 10