Skip to content

S
scheduler
Commit 9778efce authored by vicotor's avatar vicotor
Browse files
Options

update kafka config

parent 470a1620
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
server/node.go
View file @ 9778efce
...@@ -271,8 +271,8 @@ func attachKafkaConsumer(ctx context.Context, taskCh chan *odysseus.TaskContent, ...@@ -271,8 +271,8 @@ func attachKafkaConsumer(ctx context.Context, taskCh chan *odysseus.TaskContent,
config := sarama.NewConfig() config := sarama.NewConfig()
config.Consumer.Return.Errors = true config.Consumer.Return.Errors = true
config.Consumer.Group.Rebalance.GroupStrategies = []sarama.BalanceStrategy{sarama.NewBalanceStrategyRoundRobin()} config.Consumer.Group.Rebalance.GroupStrategies = []sarama.BalanceStrategy{sarama.NewBalanceStrategyRoundRobin()}
config.Consumer.Offsets.Initial = sarama.OffsetOldest //config.Consumer.Offsets.Initial = sarama.OffsetOldest
//config.Consumer.Offsets.Initial = sarama.OffsetNewest config.Consumer.Offsets.Initial = sarama.OffsetNewest
// split broker to list // split broker to list
brokers := strings.Split(n.conf.Kafka.Brokers, ";") brokers := strings.Split(n.conf.Kafka.Brokers, ";")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment