Ver código fonte

update config

Signed-off-by: AE86 <836391306@qq.com>
AE86 2 anos atrás
pai
commit
157ff54d1b

+ 1 - 1
dbsyncer-common/src/main/java/org/dbsyncer/common/config/IncrementDataConfig.java

@@ -9,7 +9,7 @@ import org.springframework.context.annotation.Configuration;
  * @date 2022/9/21 22:20
  */
 @Configuration
-@ConfigurationProperties(prefix = "dbsyncer.parser.flush.data.increment")
+@ConfigurationProperties(prefix = "dbsyncer.parser.flush.data")
 public class IncrementDataConfig {
 
     /**

+ 2 - 2
dbsyncer-parser/src/main/java/org/dbsyncer/parser/flush/impl/StorageBufferActuator.java

@@ -20,8 +20,8 @@ public class StorageBufferActuator extends AbstractBufferActuator<StorageRequest
     private StorageService storageService;
 
     @Override
-    protected String getPartitionKey(StorageRequest bufferTask) {
-        return bufferTask.getMetaId();
+    protected String getPartitionKey(StorageRequest request) {
+        return request.getMetaId();
     }
 
     @Override

+ 3 - 3
dbsyncer-web/src/main/resources/application.properties

@@ -10,9 +10,9 @@ server.servlet.context-path=/
 
 #parser
 dbsyncer.parser.flush.data.full.enabled=false
-dbsyncer.parser.flush.data.increment.writer-success=true
-dbsyncer.parser.flush.data.increment.writer-fail=true
-dbsyncer.parser.flush.data.increment.max-error-length=2048
+dbsyncer.parser.flush.data.writer-success=true
+dbsyncer.parser.flush.data.writer-fail=true
+dbsyncer.parser.flush.data.max-error-length=2048
 dbsyncer.parser.flush.buffer.actuator.speed.enabled=true
 dbsyncer.parser.flush.buffer.actuator.writer-batch-count=100
 dbsyncer.parser.flush.buffer.actuator.batch-count=1000

+ 1 - 1
dbsyncer-web/src/main/resources/public/mapping/editTableGroup.html

@@ -8,7 +8,7 @@
             <!-- 标题 -->
             <div class="row text-center">
                 <h3>[[${mapping?.name}]]</h3>
-                <p>&nbsp;</p>
+                <p>[[${tableGroup?.id}]]</p>
             </div>
 
             <!-- 驱动信息面板 -->