File tree Expand file tree Collapse file tree 1 file changed +15
-1
lines changed Expand file tree Collapse file tree 1 file changed +15
-1
lines changed Original file line number Diff line number Diff line change @@ -673,6 +673,7 @@ func (c *Client) queryPublisherSequence(publisherReference string, stream string
673
673
}
674
674
675
675
func (c * Client ) BrokerLeader (stream string ) (* Broker , error ) {
676
+
676
677
streamsMetadata := c .metaData (stream )
677
678
if streamsMetadata == nil {
678
679
return nil , fmt .Errorf ("leader error for stream for stream: %s" , stream )
@@ -685,9 +686,22 @@ func (c *Client) BrokerLeader(stream string) (*Broker, error) {
685
686
if streamMetadata .Leader == nil {
686
687
return nil , LeaderNotReady
687
688
}
688
-
689
689
streamMetadata .Leader .advPort = streamMetadata .Leader .Port
690
690
streamMetadata .Leader .advHost = streamMetadata .Leader .Host
691
+
692
+ _ , err := net .LookupIP (streamMetadata .Leader .Host )
693
+ if err != nil {
694
+ var dnsError * net.DNSError
695
+ if errors .As (err , & dnsError ) {
696
+ if strings .EqualFold (c .broker .Host , "localhost" ) {
697
+ logs .LogWarn ("DNS error: %s, trying to use localhost" , dnsError )
698
+ streamMetadata .Leader .Host = "localhost"
699
+ } else {
700
+ logs .LogWarn ("DNS error: %s" )
701
+ }
702
+ }
703
+ }
704
+
691
705
return streamMetadata .Leader , nil
692
706
}
693
707
You can’t perform that action at this time.
0 commit comments