test-version22
/
MeterSphere
mirror of https://gitee.com/fit2cloud-feizhiyun/MeterSphere.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor(性能测试): 修改Kafka acks配置

This commit is contained in:
Captain.B 2020-09-18 10:55:36 +08:00
parent 18c300f85e
commit 316617d04a
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
backend/src/main/java/io/metersphere/config/KafkaProperties.java
View File

@ -10,7 +10,7 @@ import org.springframework.boot.context.properties.ConfigurationProperties;
public class KafkaProperties { public class KafkaProperties {
public static final String KAFKA_PREFIX = "kafka"; public static final String KAFKA_PREFIX = "kafka";
private String acks; private String acks = "all";
private String topic; private String topic;
private String fields; private String fields;
private String timestamp; private String timestamp;

1
backend/src/main/resources/application.properties
View File

@ -40,7 +40,6 @@ spring.flyway.validate-on-migrate=false
spring.messages.basename=i18n/messages spring.messages.basename=i18n/messages
# kafka # kafka
kafka.acks=1
kafka.fields= kafka.fields=
kafka.timestamp=yyyy-MM-dd'T'HH:mm:ss.SSSZZ kafka.timestamp=yyyy-MM-dd'T'HH:mm:ss.SSSZZ
kafka.sample-filter= kafka.sample-filter=