es_hk_images_dumps3/src/main/resources/application-prod.yml

#118
server:
  port: 8070
spring:
  devtools.restart.enabled: true
  kafka:
    bootstrap-servers: app2833:9094,app2834:9094,app2835:9094,app2836:9094,app2837:9094
    #bootstrap-servers: localhost:9092
    producer:
      # 发生错误后，消息重发的次数。
      retries: 1
      #当有多个消息需要被发送到同一个分区时，生产者会把它们放在同一个批次里。该参数指定了一个批次可以使用的内存大小，按照字节数计算。
      batch-size: 16384
      # 设置生产者内存缓冲区的大小。
      buffer-memory: 33554432
      # 键的序列化方式
      key-serializer: org.springframework.kafka.support.serializer.JsonSerializer
      # 值的序列化方式
      value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
      # acks=0 ： 生产者在成功写入消息之前不会等待任何来自服务器的响应。
      # acks=1 ： 只要集群的首领节点收到消息，生产者就会收到一个来自服务器成功响应。
      # acks=all ：只有当所有参与复制的节点全部收到消息时，生产者才会收到一个来自服务器的成功响应。
      acks: all
    consumer:
      # 自动提交的时间间隔 在spring boot 2.X 版本中这里采用的是值的类型为Duration 需要符合特定的格式，如1S,1M,2H,5D
      auto-commit-interval: 1S
      # 该属性指定了消费者在读取一个没有偏移量的分区或者偏移量无效的情况下该作何处理：
      # latest（默认值）在偏移量无效的情况下，消费者将从最新的记录开始读取数据（在消费者启动之后生成的记录）
      # earliest ：在偏移量无效的情况下，消费者将从起始位置读取分区的记录
      auto-offset-reset: latest
      # 是否自动提交偏移量，默认值是true,为了避免出现重复数据和数据丢失，可以把它设置为false,然后手动提交偏移量
      enable-auto-commit: false
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      # 批量消费一次最大拉取的数据量
      max-poll-records: 1000
    properties:
      security:
        protocol: SASL_PLAINTEXT
      sasl:
        mechanism: SCRAM-SHA-512
        jaas:
          config: 'org.apache.kafka.common.security.scram.ScramLoginModule required username="user01" password="8b9dcf43";'
    listener:
      # 在侦听器容器中运行的线程数。
      concurrency: 5
      #listner负责ack，每调用一次，就立即commit
      ack-mode: manual_immediate
      missing-topics-fatal: false
      type: batch
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://74.10.28.86:3389/ax_seat_1?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
    username: ax_tj_seat
    password: Taiji@2022#seat
#    streams:
#      auto-startup: false

taiji:
  openservice:
    enable: true
    url: http://74.10.28.87:9002
  elasticsearch.rest:
    uris: 74.10.28.65:9200,74.10.28.65:9201,74.10.28.65:9202,74.10.28.66:9200,74.10.28.66:9201,74.10.28.66:9202,74.10.28.67:9200,74.10.28.67:9201,74.10.28.67:9202,74.10.28.68:9200,74.10.28.68:9201,74.10.28.68:9202,74.10.28.69:9200,74.10.28.69:9201,74.10.28.69:9202
    username: ax_seat       #如果你设置了基于x-pack的验证就要填写账号和密码
    password: ax_seat       #没有则不用配置
    connection-timeout: 100 #连接超时
    max-connection: 100  #最大连接数
  hbase.zookeeper:
    quorum: hadoop7:2181,hadoop8:2181,hadoop9:2181,hadoop16:2181,hadoop17:2181
    znode_parent: /hbase-unsecure
  kafka:
    consumer:
      groupId: 202303261619_xhl_es
      hik-capture-face:
        group: ${random.uuid}
        topic: 'taiji_ax_hik_capture_face'
        partitions0: 0
        partitions1: 1
        partitions2: 2
        partitions3: 3
        partitions4: 4
      hik-capture-car:
        group: ${random.uuid}
        topic: 'taiji_ax_hik_capture_car'
        partitions0: 0
        partitions1: 1
        partitions2: 2
        partitions3: 3
        partitions4: 4
      hik-capture-ship:
        group: ${random.uuid}
        topic: 'ship_camera_structured_info'
        partitions0: 0
        partitions1: 1
        partitions2: 2
        partitions3: 3
        partitions4: 4
      tile: false
      prefix:
        ztpt_dynamic_ais_key_prefix: ZTPT_DYNAMIC_AIS_118_
        tianao_radar_fusion_key_prefix: TIANAO_RADAR_FUSION_118_
        dynamic_ship_track_geo_name_key: DYNAMIC_SHIP_TRACK_GEO_NAME_KEY_118_
        dynamic_ship_track_geo_key: dynamic_ship_track_geo_key_118_
        trake_user_prefix: trake_user_prefix_118_
        trake_dept_prefix: trake_dept_prefix_118_
        ship_borne_terminal_redis_key_prefix: ship_borne_terminal_118_
        static_beidou_law_enforcement_ship_redis_key_prefix: STATIC_BEIDOU_LAW_ENFORCEMENT_SHIP_118_
        static_police_man_track_redis_key_prefix: STATIC_POLICE_MAN_TRACK_REDIS_118_
        static_law_enforcement_car_redis_key_prefix: STATIC_LAW_ENFORCEMENT_CAR_118_;
        hlx_ais_redis_key_prefix: hlx_ais_redis_key_prefix_116_
        hlx_dynamic_radar_redis_key_prefix: hlx_dynamic_radar_redis_key_prefix_116_
        hlx_zyh_redis_key_prefix: hlx_zyh_redis_key_prefix_116_
    producer:
      police_ship_fusion_track:
        topic: taiji_ax_police_ship_fusion_track
        group: ${random.uuid}
        partitions0: 0
        partitions1: 1
        partitions2: 2
        partitions3: 3
        partitions4: 4
      police_car_fusion_track:
        topic: taiji_ax_police_car_fusion_track
        group: ${random.uuid}
        partitions0: 0
        partitions1: 1
        partitions2: 2
        partitions3: 3
        partitions4: 4
      police_man_fusion_track:
        topic: taiji_ax_police_man_fusion_track
        group: ${random.uuid}
        partitions0: 0
        partitions1: 1
        partitions2: 2
        partitions3: 3
        partitions4: 4
logging:
  basePath: /app/dynamicTrackEs59/logs
  config: classpath:log-config/logback-spring.xml
  # 本地开发环境通过level控制
  level:
    root: info
    cn.com.taiji: trace
    org.springframework.web: debug

##amazon-s3
file:
  store:
    endpoint: http://74.10.28.62:81
    access-key: ax_seat_acc
    secret-key: ax_seat_AxSeatPW
    bucket: ax_es_hik_images
    prefix: ax_es_hik_images
    domain: http://74.10.28.62:81/
    ip: 74.10.28.62
    port: 81
    httpOnly: 0