From f9cf764fb5a4456227751790622a7f7d41a48eea Mon Sep 17 00:00:00 2001 From: wangyuchen Date: Wed, 8 Jan 2020 19:52:41 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8F=90=E4=BA=A4?= =?UTF-8?q?=E6=97=B6=E9=97=B4=E9=97=B4=E9=9A=94?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .idea/codeStyles/codeStyleConfig.xml | 5 +++++ .idea/vcs.xml | 6 ++++++ consumer.go | 2 +- 3 files changed, 12 insertions(+), 1 deletion(-) create mode 100644 .idea/codeStyles/codeStyleConfig.xml create mode 100644 .idea/vcs.xml diff --git a/.idea/codeStyles/codeStyleConfig.xml b/.idea/codeStyles/codeStyleConfig.xml new file mode 100644 index 0000000..79ee123 --- /dev/null +++ b/.idea/codeStyles/codeStyleConfig.xml @@ -0,0 +1,5 @@ + + + + \ No newline at end of file diff --git a/.idea/vcs.xml b/.idea/vcs.xml new file mode 100644 index 0000000..94a25f7 --- /dev/null +++ b/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/consumer.go b/consumer.go index 56a6d07..3f0b3ce 100644 --- a/consumer.go +++ b/consumer.go @@ -449,7 +449,7 @@ func (c *Consumer) twLoop(stopped <-chan none) { // commit loop, triggered by the mainLoop func (c *Consumer) cmLoop(stopped <-chan none) { - ticker := time.NewTicker(c.client.config.Consumer.Offsets.CommitInterval) + ticker := time.NewTicker(c.client.config.Consumer.Offsets.AutoCommit.Interval) defer ticker.Stop() for { From 95c44d29f40854948ae2f2b41355093eb4a658fd Mon Sep 17 00:00:00 2001 From: wangyuchen Date: Wed, 8 Jan 2020 19:56:56 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8F=90=E4=BA=A4?= =?UTF-8?q?=E6=97=B6=E9=97=B4=E9=97=B4=E9=9A=94?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .idea/codeStyles/codeStyleConfig.xml | 5 ----- .idea/vcs.xml | 6 ------ 2 files changed, 11 deletions(-) delete mode 100644 .idea/codeStyles/codeStyleConfig.xml delete mode 100644 .idea/vcs.xml diff --git a/.idea/codeStyles/codeStyleConfig.xml b/.idea/codeStyles/codeStyleConfig.xml deleted file mode 100644 index 79ee123..0000000 --- a/.idea/codeStyles/codeStyleConfig.xml +++ /dev/null @@ -1,5 +0,0 @@ - - - - \ No newline at end of file diff --git a/.idea/vcs.xml b/.idea/vcs.xml deleted file mode 100644 index 94a25f7..0000000 --- a/.idea/vcs.xml +++ /dev/null @@ -1,6 +0,0 @@ - - - - - - \ No newline at end of file