pkg/stream: fix the error that could occur due to nil option (#331)

bailantaotao · web-flow · commit baed3d514424 · 2024-07-12T10:24:37.000+02:00
diff --git a/pkg/stream/environment.go b/pkg/stream/environment.go
@@ -573,7 +573,7 @@ func (cc *environmentCoordinator) newProducer(leader *Broker, tcpParameters *TCP
 		if err != nil {
 			return nil, err
 		}
-		clientResult = cc.newClientForProducer(options.ClientProvidedName, leader, tcpParameters, saslConfiguration, rpcTimeout)
+		clientResult = cc.newClientForProducer(clientProvidedName, leader, tcpParameters, saslConfiguration, rpcTimeout)
 		err = clientResult.connect()
 		if err != nil {
 			return nil, err

Original file line number	Diff line number	Diff line change
`@@ -573,7 +573,7 @@ func (cc environmentCoordinator) newProducer(leader Broker, tcpParameters *TCP`
`573`	`573`	`if err != nil {`
`574`	`574`	`return nil, err`
`575`	`575`	`}`
`576`		`- clientResult = cc.newClientForProducer(options.ClientProvidedName, leader, tcpParameters, saslConfiguration, rpcTimeout)`
	`576`	`+ clientResult = cc.newClientForProducer(clientProvidedName, leader, tcpParameters, saslConfiguration, rpcTimeout)`
`577`	`577`	`err = clientResult.connect()`
`578`	`578`	`if err != nil {`
`579`	`579`	`return nil, err`