From c42616815a61013d669644644b9843aeebba3c28 Mon Sep 17 00:00:00 2001 From: zhuyulei Date: Tue, 19 Sep 2023 15:43:38 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E4=BD=99=E9=85=8D=E7=BD=AE=E5=88=A0?= =?UTF-8?q?=E9=99=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- jwtech-admin/pom.xml | 4 +- .../src/main/resources/application-test.yml | 126 +++++++++--------- pom.xml | 4 +- 3 files changed, 67 insertions(+), 67 deletions(-) diff --git a/jwtech-admin/pom.xml b/jwtech-admin/pom.xml index 56aeef40..779e1918 100644 --- a/jwtech-admin/pom.xml +++ b/jwtech-admin/pom.xml @@ -28,11 +28,11 @@ 2.2.6 - + diff --git a/jwtech-admin/src/main/resources/application-test.yml b/jwtech-admin/src/main/resources/application-test.yml index 7b1dc00e..05b32afb 100644 --- a/jwtech-admin/src/main/resources/application-test.yml +++ b/jwtech-admin/src/main/resources/application-test.yml @@ -45,63 +45,63 @@ logging: level: com.kms: debug org.springframework: warn -thrift: - host: 192.168.0.61 - port: 9710 - timeOut: 60000 - maxActive: 20000 - max-total: 50 - max-idle: 10 - min-idle: 5 - max-wait-millis: 200 - indexName: tianhui_cg - indexType: doc - esEntity: com.kms.system.es.EsEntity +#thrift: +# host: 192.168.0.61 +# port: 9710 +# timeOut: 60000 +# maxActive: 20000 +# max-total: 50 +# max-idle: 10 +# min-idle: 5 +# max-wait-millis: 200 +# indexName: tianhui_cg +# indexType: doc +# esEntity: com.kms.system.es.EsEntity # Spring配置 spring: - kafka: - autoStartup: false - topics: tianhui - # kafka信息 http://182.92.86.163:9092/ - bootstrap-servers: 106.2.224.58:8021 - #bootstrap-servers: 182.92.86.163:9092 - producer: # 生产者配置 - retries: 3 # 设置大于0的值,则客户端会将发送失败的记录重新发送 - batch-size: 33554432 #32M - buffer-memory: 33554432 #32M - acks: 1 - # 指定消息key和消息体的编解码方式 - key-serializer: org.apache.kafka.common.serialization.StringSerializer - value-serializer: org.apache.kafka.common.serialization.StringSerializer - consumer: - session: - timeout: 200000000 # 链接超时时间 - group-id: jianweikeji # 消费者组 - enable-auto-commit: false # 关闭自动提交 - auto-offset-reset: earliest # 当各分区下有已提交的offset时,从提交的offset开始消费;无提交的offset时,从头开始消费 - key-deserializer: org.apache.kafka.common.serialization.StringDeserializer - value-deserializer: org.apache.kafka.common.serialization.StringDeserializer - listener: - # 当每一条记录被消费者监听器(ListenerConsumer)处理之后提交 - # RECORD - # 当每一批poll()的数据被消费者监听器(ListenerConsumer)处理之后提交 - # BATCH - # 当每一批poll()的数据被消费者监听器(ListenerConsumer)处理之后,距离上次提交时间大于TIME时提交 - # TIME - # 当每一批poll()的数据被消费者监听器(ListenerConsumer)处理之后,被处理record数量大于等于COUNT时提交 - # COUNT - # TIME | COUNT 有一个条件满足时提交 - # COUNT_TIME - # 当每一批poll()的数据被消费者监听器(ListenerConsumer)处理之后, 手动调用Acknowledgment.acknowledge()后提交 - # MANUAL - # 手动调用Acknowledgment.acknowledge()后立即提交,一般使用这种 - # MANUAL_IMMEDIATE - ack-mode: manual_immediate - data: - neo4j: - uri: bolt://192.168.0.61:7687 - username: neo4j - password: password +# kafka: +# autoStartup: false +# topics: tianhui +# # kafka信息 http://182.92.86.163:9092/ +# bootstrap-servers: 106.2.224.58:8021 +# #bootstrap-servers: 182.92.86.163:9092 +# producer: # 生产者配置 +# retries: 3 # 设置大于0的值,则客户端会将发送失败的记录重新发送 +# batch-size: 33554432 #32M +# buffer-memory: 33554432 #32M +# acks: 1 +# # 指定消息key和消息体的编解码方式 +# key-serializer: org.apache.kafka.common.serialization.StringSerializer +# value-serializer: org.apache.kafka.common.serialization.StringSerializer +# consumer: +# session: +# timeout: 200000000 # 链接超时时间 +# group-id: jianweikeji # 消费者组 +# enable-auto-commit: false # 关闭自动提交 +# auto-offset-reset: earliest # 当各分区下有已提交的offset时,从提交的offset开始消费;无提交的offset时,从头开始消费 +# key-deserializer: org.apache.kafka.common.serialization.StringDeserializer +# value-deserializer: org.apache.kafka.common.serialization.StringDeserializer +# listener: +# # 当每一条记录被消费者监听器(ListenerConsumer)处理之后提交 +# # RECORD +# # 当每一批poll()的数据被消费者监听器(ListenerConsumer)处理之后提交 +# # BATCH +# # 当每一批poll()的数据被消费者监听器(ListenerConsumer)处理之后,距离上次提交时间大于TIME时提交 +# # TIME +# # 当每一批poll()的数据被消费者监听器(ListenerConsumer)处理之后,被处理record数量大于等于COUNT时提交 +# # COUNT +# # TIME | COUNT 有一个条件满足时提交 +# # COUNT_TIME +# # 当每一批poll()的数据被消费者监听器(ListenerConsumer)处理之后, 手动调用Acknowledgment.acknowledge()后提交 +# # MANUAL +# # 手动调用Acknowledgment.acknowledge()后立即提交,一般使用这种 +# # MANUAL_IMMEDIATE +# ack-mode: manual_immediate +# data: +# neo4j: +# uri: bolt://192.168.0.61:7687 +# username: neo4j +# password: password # mongodb: # uri: mongodb://192.168.0.61:27017/tianhui_cg # field-naming-strategy: org.springframework.data.mapping.model.SnakeCaseFieldNamingStrategy @@ -239,11 +239,11 @@ http: socketTimeout: 5000000 validateAfterInactivity: 300000 #算法配置 -algorithm: - #图片ocr服务 - entity: http://192.168.0.14:17856/analyze_text - # 自动打抽取摘要 - summary: http://192.168.0.210:12343 - ocr: http://192.168.0.62:12340/ExtractServer?WSDL - #内容是文件类型识别 - fielTypeAndContent: http://192.168.0.42:8089/detect +#algorithm: +# #图片ocr服务 +# entity: http://192.168.0.14:17856/analyze_text +# # 自动打抽取摘要 +# summary: http://192.168.0.210:12343 +# ocr: http://192.168.0.62:12340/ExtractServer?WSDL +# #内容是文件类型识别 +# fielTypeAndContent: http://192.168.0.42:8089/detect diff --git a/pom.xml b/pom.xml index 105de4a9..b75cece7 100644 --- a/pom.xml +++ b/pom.xml @@ -91,11 +91,11 @@ 1.0-SNAPSHOT - + org.jsoup