#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.66:9200,74.10.28.67:9200,74.10.28.68:9200,74.10.28.69:9200 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: 202206150922_118_es ship_warning_record: topic: 'taiji_ax_ship_warning_record' group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 multiple_warning_record: topic: 'taiji_ax_multiple_warning_record' group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 car_warning_record: topic: 'taiji_ax_car_warning_record' group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 person_warning_record: topic: 'taiji_ax_person_warning_record' group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 ztpt_dynamic_ais: group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 topic: 'taiji_ax_ztpt_dynamic_ais' id-key: 'userid' longitude-key: 'longitude' latitude-key: 'latitude' hlx_ax_dynamic_target_ais: group: ${random.uuid} topic: 'hlx_ax_dynamic_target_ais' partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 hlx_ax_dynamic_target_radar: group: ${random.uuid} topic: 'hlx_ax_dynamic_target_radar' partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 hlx_ax_dynamic_target_zyh_radar: group: ${random.uuid} topic: 'hlx_ax_dynamic_target_zyh_radar' partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 beidou-dynamic-ship: group: ${random.uuid} topic: 'taiji_ax_beidou_dynamic_ship' partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 tianao_radar_fusion: group: ${random.uuid} topic: 'taiji_ax_tianao_radar_fusion' latitude-key: 'latitude' longitude-key: 'longitude' id-key: 'fusionBatchNum' partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 pdt_data_track: topic: 't_pdt_data_receive' group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 dynamic-mobile-track: group: ${random.uuid} topic: 'ax_mobile_dynamic_track' partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 dvr_track: group: ${random.uuid} topic: 'taiji_ax_dvr_track' partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 dynamic-ship-track: topic: 'taiji_ax_ship_dynamic_fusion' id-key: 'merge_target' longitude-key: 'target_longitude' latitude-key: 'target_latitude' group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 dynamic-ship-track-gis: topic: 'taiji_ax_ship_dynamic_fusion_gis' id-key: 'merge_target' longitude-key: 'target_longitude' latitude-key: 'target_latitude' group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 dynamic-fk-ship-track-gis: topic: 'taiji_ax_fk_ship_dynamic_fusion_gis' id-key: 'merge_target' longitude-key: 'target_longitude' latitude-key: 'target_latitude' group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 dynamic-fk-track-ship-partition: topic: 'taiji_ax_fk_dynamic_fusion_ship' group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 dynamic-ship-track-partition: topic: 'taiji_ax_ship_dynamic_fusion' group: ${random.uuid} partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 id-key: merge_id longitude-key: target_longitude latitude-key: target_latitude 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 taiji_hik_face: group: ${random.uuid} topic: 'ax_taiji_hik_face' partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 taiji_ax_hlx_zww_dynamic_fusion_ship: group: ${random.uuid} topic: 'taiji_ax_hlx_zww_dynamic_fusion_ship' partitions0: 0 partitions1: 1 partitions2: 2 partitions3: 3 partitions4: 4 taiji_ax_hlx_zww_dynamic_fusion_ship_gis: group: ${random.uuid} topic: 'taiji_ax_hlx_zww_dynamic_fusion_ship_gis' 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