Skip to content

Commit

Permalink
Changed order of config variables
Browse files Browse the repository at this point in the history
  • Loading branch information
Excaleo authored and irisgve committed Oct 14, 2020
1 parent f44f976 commit 25a0afd
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion exporter/kinesisexporter/exporter.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,7 @@ func newKinesisExporter(c *Config, logger *zap.Logger) (*Exporter, error) {
client := kinesis.New(sess)

pr := producer.New(&producer.Config{
Logger: &kpzap.Logger{Logger: logger},
Client: client,
StreamName: c.AWS.StreamName,
// KPL parameters
Expand All @@ -67,7 +68,6 @@ func newKinesisExporter(c *Config, logger *zap.Logger) (*Exporter, error) {
MaxConnections: c.KPL.MaxConnections,
MaxRetries: c.KPL.MaxRetries,
MaxBackoffTime: time.Duration(c.KPL.MaxBackoffSeconds) * time.Second,
Logger: &kpzap.Logger{Logger: logger},
}, nil)
return &Exporter{producer: pr, marshaller: marshaller, logger: logger}, nil
}
Expand Down

0 comments on commit 25a0afd

Please sign in to comment.