Skip to content

Commit

Permalink
fix: InitConsumerWorker
Browse files Browse the repository at this point in the history
  • Loading branch information
crimson-gao committed Aug 14, 2024
1 parent 0bbc541 commit 77342bb
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions consumer/worker.go
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package consumerLibrary

import (
"os"
"io"
"os"
"sync"
"time"

Expand All @@ -23,10 +23,10 @@ type ConsumerWorker struct {
Logger log.Logger
}

// depreciated: this old logic is to automatically save to memory, and then commit at a fixed time
// deprecated: this old logic is to automatically save to memory, and then commit at a fixed time
// we highly recommend you to use InitConsumerWorkerWithCheckpointTracker
func InitConsumerWorker(option LogHubConfig, do func(int, *sls.LogGroupList) string) *ConsumerWorker {
if option.AutoCommitDisabled {
if !option.AutoCommitDisabled {
panic("auto commit already disabled, sdk will not save any checkpoint, " +
"please use InitConsumerWorkerWithCheckpointTracker or set AutoCommitDisabled to false")
}
Expand Down

0 comments on commit 77342bb

Please sign in to comment.