Skip to content

Commit 3b697d8

Browse files
authored
fix new producer log (#346)
1 parent 174fa0c commit 3b697d8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/stream/environment.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -566,7 +566,7 @@ func (cc *environmentCoordinator) newProducer(leader *Broker, tcpParameters *TCP
566566

567567
for clientResult.connectionProperties.host != leader.advHost ||
568568
clientResult.connectionProperties.port != leader.advPort {
569-
logs.LogDebug("connectionProperties host %s doesn't mach with the advertised_host %s, advertised_port %d .. retry",
569+
logs.LogDebug("connectionProperties host %s doesn't match with the advertised_host %s, advertised_port %s .. retry",
570570
clientResult.connectionProperties.host,
571571
leader.advHost, leader.advPort)
572572
err := clientResult.Close()

0 commit comments

Comments
 (0)