Skip to content

Commit

Permalink
Fix Jaeger Test
Browse files Browse the repository at this point in the history
Signed-off-by: kennyaz <[email protected]>
  • Loading branch information
kennyaz committed Jul 14, 2023
1 parent fe3f45a commit d23a9ae
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion pkg/kafka/consumer/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,5 @@ func (c *Configuration) NewConsumer(logger *zap.Logger) (Consumer, error) {
// that does not set saramaConfig.Consumer.Offsets.CommitInterval to its default value 1s.
// then the samara-cluster fails if the default interval is not 1s.
saramaConfig.Consumer.Offsets.CommitInterval = time.Second

return cluster.NewConsumer(c.Brokers, c.GroupID, []string{c.Topic}, saramaConfig)
}

0 comments on commit d23a9ae

Please sign in to comment.