Skip to content

Commit

Permalink
Remove logging on info level from kafka service
Browse files Browse the repository at this point in the history
  • Loading branch information
alenkacz committed Jun 3, 2022
1 parent f97e56e commit 993614d
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion kafka/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ func (s *Service) CreateAndTestClient(ctx context.Context, l *zap.Logger, opts [
// testConnection tries to fetch Broker metadata and prints some information if connection succeeds. An error will be
// returned if connecting fails.
func (s *Service) testConnection(client *kgo.Client, ctx context.Context) error {
s.logger.Info("connecting to Kafka seed brokers, trying to fetch cluster metadata",
s.logger.Debug("connecting to Kafka seed brokers, trying to fetch cluster metadata",
zap.String("seed_brokers", strings.Join(s.cfg.Brokers, ",")))

req := kmsg.MetadataRequest{
Expand Down

0 comments on commit 993614d

Please sign in to comment.