kaiyan-index: remove debug logging
This commit is contained in:
parent
b2f3a2ed87
commit
039013abb6
@ -77,7 +77,6 @@ func main() {
|
|||||||
kgo.ConsumeTopics(queue.Topic),
|
kgo.ConsumeTopics(queue.Topic),
|
||||||
kgo.FetchIsolationLevel(kgo.ReadCommitted()),
|
kgo.FetchIsolationLevel(kgo.ReadCommitted()),
|
||||||
kgo.GreedyAutoCommit(),
|
kgo.GreedyAutoCommit(),
|
||||||
kgo.WithLogger(kgo.BasicLogger(os.Stderr, kgo.LogLevelDebug, nil)),
|
|
||||||
)
|
)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fail("%v", err)
|
fail("%v", err)
|
||||||
|
Loading…
Reference in New Issue
Block a user