This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git
commit f9ab6e462308b6447df310b6c60dd511f577336d Author: CMonkey <42.codemon...@gmail.com> AuthorDate: Wed Aug 14 10:42:24 2019 +0800 SCB-1418 change spring.kafka.consumer.enable.auto.commit default value to false --- alpha/alpha-fsm-channel-kafka/README.md | 2 +- .../pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/alpha/alpha-fsm-channel-kafka/README.md b/alpha/alpha-fsm-channel-kafka/README.md index 6e9455d..5a63b47 100644 --- a/alpha/alpha-fsm-channel-kafka/README.md +++ b/alpha/alpha-fsm-channel-kafka/README.md @@ -18,6 +18,6 @@ spring.kafka.producer.batch-size= producer batch size, default 16384 spring.kafka.producer.retries = producer retries, default 0 spring.kafka.producer.buffer.memory = producer buffer memory, default 33364432 spring.kafka.consumer.auto.offset.reset = consumer auto offset reset, default earliest -spring.kafka.consumer.enable.auto.commit = consumer enable auto commit, default true +spring.kafka.consumer.enable.auto.commit = consumer enable auto commit, default false spring.kafka.consumer.auto.commit.interval.ms = consumer auto commit interval ms, default 100 ``` diff --git a/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java b/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java index ac38098..6a451ec 100644 --- a/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java +++ b/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java @@ -73,7 +73,7 @@ public class KafkaChannelAutoConfiguration { @Value("${spring.kafka.consumer.auto.offset.reset:earliest}") private String autoOffsetReset; - @Value("${spring.kafka.consumer.enable.auto.commit:true}") + @Value("${spring.kafka.consumer.enable.auto.commit:false}") private boolean enableAutoCommit; @Value("${spring.kafka.consumer.auto.commit.interval.ms:100}")