diff --git a/internal/databroker/config_source.go b/internal/databroker/config_source.go index 6e62271ea..3e7996913 100644 --- a/internal/databroker/config_source.go +++ b/internal/databroker/config_source.go @@ -197,7 +197,19 @@ func (src *ConfigSource) runUpdater(cfg *config.Config) { src: src, }, databroker.WithTypeURL(grpcutil.GetTypeURL(new(configpb.Config))), databroker.WithFastForward()) - go func() { _ = syncer.Run(ctx) }() + go func() { + var databrokerURLs []string + urls, _ := cfg.Options.GetDataBrokerURLs() + for _, url := range urls { + databrokerURLs = append(databrokerURLs, url.String()) + } + + log.Info(ctx). + Str("outbound_port", cfg.OutboundPort). + Strs("databroker_urls", databrokerURLs). + Msg("config: starting databroker config source syncer") + _ = syncer.Run(ctx) + }() } type syncerHandler struct {