Skip to content

Commit

Permalink
Reword log
Browse files Browse the repository at this point in the history
Signed-off-by: Davit Yeghshatyan <davo@uber.com>
  • Loading branch information
Davit Yeghshatyan committed Jul 25, 2018
1 parent 1399f4f commit 4f7729b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions plugin/storage/kafka/factory.go
Original file line number Diff line number Diff line change
Expand Up @@ -59,8 +59,8 @@ func (f *Factory) InitFromViper(v *viper.Viper) {
// Initialize implements storage.Factory
func (f *Factory) Initialize(metricsFactory metrics.Factory, logger *zap.Logger) error {
f.metricsFactory, f.logger = metricsFactory, logger
logger.Info("Kafka producer builder",
zap.Any("producer builder", f.Builder),
logger.Info("Kafka factory",
zap.Any("producer factory", f.Builder),
zap.Any("topic", f.options.topic))
p, err := f.NewProducer()
if err != nil {
Expand Down

0 comments on commit 4f7729b

Please sign in to comment.