diff --git a/internal/pkg/vpagent/changeEvent.go b/internal/pkg/vpagent/changeEvent.go
index d63abe7..e975396 100644
--- a/internal/pkg/vpagent/changeEvent.go
+++ b/internal/pkg/vpagent/changeEvent.go
@@ -33,7 +33,7 @@
 		logger.Debug(ctx, "receive-change-events-finished")
 	}()
 	if vpa.volthaClient == nil {
-		logger.Error(ctx, "no-voltha-connection")
+		logger.Fatal(ctx, "no-voltha-connection")
 		return
 	}
 	opt := grpc.EmptyCallOption{}
@@ -74,7 +74,7 @@
 					log.Fields{"error": err})
 				break top
 			} else if err != nil {
-				logger.Infow(ctx, "Ignoring unhandled error", log.Fields{"err": err})
+				logger.Warnw(ctx, "Ignoring unhandled error", log.Fields{"err": err})
 				continue
 			}
 			vpa.changeEventChannel <- ce
diff --git a/internal/pkg/vpagent/connection.go b/internal/pkg/vpagent/connection.go
index e90eab1..21aa569 100644
--- a/internal/pkg/vpagent/connection.go
+++ b/internal/pkg/vpagent/connection.go
@@ -63,7 +63,7 @@
 				}
 			}
 		}
-		logger.Warnw(ctx, "Failed to connect to voltha",
+		logger.Fatalw(ctx, "Failed to connect to voltha",
 			log.Fields{
 				"VolthaApiEndPoint": vpa.VolthaAPIEndPoint,
 				"error":             err.Error(),
diff --git a/internal/pkg/vpagent/packetIn.go b/internal/pkg/vpagent/packetIn.go
index aadf19f..f7483a6 100644
--- a/internal/pkg/vpagent/packetIn.go
+++ b/internal/pkg/vpagent/packetIn.go
@@ -33,7 +33,7 @@
 		logger.Debug(ctx, "receive-packets-in-finished")
 	}()
 	if vpa.volthaClient == nil {
-		logger.Error(ctx, "no-voltha-connection")
+		logger.Fatal(ctx, "no-voltha-connection")
 		return
 	}
 	opt := grpc.EmptyCallOption{}
@@ -70,7 +70,7 @@
 					log.Fields{"error": err})
 				break top
 			} else if err != nil {
-				logger.Infow(ctx, "Ignoring unhandled error", log.Fields{"err": err})
+				logger.Warnw(ctx, "Ignoring unhandled error", log.Fields{"err": err})
 				continue
 			}
 			vpa.packetInChannel <- pkt
diff --git a/internal/pkg/vpagent/packetOut.go b/internal/pkg/vpagent/packetOut.go
index d5787dd..00fbf5b 100644
--- a/internal/pkg/vpagent/packetOut.go
+++ b/internal/pkg/vpagent/packetOut.go
@@ -31,7 +31,7 @@
 		logger.Debug(ctx, "packet-out-finished")
 	}()
 	if vpa.volthaClient == nil {
-		logger.Error(ctx, "no-voltha-connection")
+		logger.Fatal(ctx, "no-voltha-connection")
 		return
 	}
 	opt := grpc.EmptyCallOption{}
diff --git a/internal/pkg/vpagent/refresh.go b/internal/pkg/vpagent/refresh.go
index 2a8f2bc..a0514cf 100644
--- a/internal/pkg/vpagent/refresh.go
+++ b/internal/pkg/vpagent/refresh.go
@@ -53,7 +53,7 @@
 func (vpa *VPAgent) refreshDeviceList(cntx context.Context) {
 	// If we exit, assume disconnected
 	if vpa.volthaClient == nil {
-		logger.Error(ctx, "no-voltha-connection")
+		logger.Fatal(ctx, "no-voltha-connection")
 		vpa.events <- vpaEventVolthaDisconnected
 		return
 	}
@@ -102,7 +102,7 @@
 }
 
 func (vpa *VPAgent) addVPClient(device *voltha.LogicalDevice) intf.IVPClient {
-	logger.Warnw(ctx, "GrpcClient addClient called ", log.Fields{"device-id": device.Id})
+	logger.Debugw(ctx, "GrpcClient addClient called ", log.Fields{"device-id": device.Id})
 	vpa.mapLock.Lock()
 	defer vpa.mapLock.Unlock()
 	var serialNum = "Unknown"