diff --git a/infra/conf/v5cfg/stream.go b/infra/conf/v5cfg/stream.go index fa49b165a..30bc60f9b 100644 --- a/infra/conf/v5cfg/stream.go +++ b/infra/conf/v5cfg/stream.go @@ -39,8 +39,9 @@ func (s StreamConfig) BuildV5(ctx context.Context) (proto.Message, error) { if err != nil { return nil, newError("unable to load security config").Base(err) } - config.SecurityType = s.Security - config.SecuritySettings = append(config.SecuritySettings, serial.ToTypedMessage(securityConfigPack)) + securityConfigPackTypedMessage := serial.ToTypedMessage(securityConfigPack) + config.SecurityType = serial.V2Type(securityConfigPackTypedMessage) + config.SecuritySettings = append(config.SecuritySettings, securityConfigPackTypedMessage) } config.SocketSettings, err = s.SocketSettings.Build()