From fc643f15c020a79d23cfc366bb1f7658e387cb03 Mon Sep 17 00:00:00 2001 From: hainenber Date: Wed, 13 Sep 2023 20:10:40 +0700 Subject: [PATCH] fix(loki/kafkatarget): use new sarama method instead of deprecated ones --- component/loki/source/internal/kafkatarget/target_syncer.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/component/loki/source/internal/kafkatarget/target_syncer.go b/component/loki/source/internal/kafkatarget/target_syncer.go index 4179d993852b..027ac5fd7073 100644 --- a/component/loki/source/internal/kafkatarget/target_syncer.go +++ b/component/loki/source/internal/kafkatarget/target_syncer.go @@ -65,11 +65,11 @@ func NewSyncer( switch cfg.KafkaConfig.Assignor { case sarama.StickyBalanceStrategyName: - config.Consumer.Group.Rebalance.Strategy = sarama.BalanceStrategySticky + config.Consumer.Group.Rebalance.Strategy = sarama.NewBalanceStrategyRange() case sarama.RoundRobinBalanceStrategyName: - config.Consumer.Group.Rebalance.Strategy = sarama.BalanceStrategyRoundRobin + config.Consumer.Group.Rebalance.Strategy = sarama.NewBalanceStrategyRoundRobin() case sarama.RangeBalanceStrategyName, "": - config.Consumer.Group.Rebalance.Strategy = sarama.BalanceStrategyRange + config.Consumer.Group.Rebalance.Strategy = sarama.NewBalanceStrategyRange() default: return nil, fmt.Errorf("unrecognized consumer group partition assignor: %s", cfg.KafkaConfig.Assignor) }