diff --git a/pkg/sink/reconciler/streamsink/streamsink.go b/pkg/sink/reconciler/streamsink/streamsink.go
index 09e7b09fa..670440f25 100644
--- a/pkg/sink/reconciler/streamsink/streamsink.go
+++ b/pkg/sink/reconciler/streamsink/streamsink.go
@@ -95,7 +95,8 @@ func (r *Reconciler) updateTLSSecret(ctx context.Context, secret *corev1.Secret)
 	tlsSecret, err := GetTLSSecret(secret.Data)
 	if err != nil {
 		logging.FromContext(ctx).Errorw("Error reading TLS configuration", zap.Error(err))
+	} else {
+		// For now just override the previous config.
+		r.tlsCert = tlsSecret.TLSCertificate
 	}
-	// For now just override the previous config.
-	r.tlsCert = tlsSecret.TLSCertificate
 }
diff --git a/pkg/source/reconciler/streamsource/streamsource.go b/pkg/source/reconciler/streamsource/streamsource.go
index 1e6eabc75..b5fc3887c 100644
--- a/pkg/source/reconciler/streamsource/streamsource.go
+++ b/pkg/source/reconciler/streamsource/streamsource.go
@@ -127,16 +127,18 @@ func (r *Reconciler) updateRedisConfig(ctx context.Context, configMap *corev1.Co
 	redisConfig, err := GetRedisConfig(configMap.Data)
 	if err != nil {
 		logging.FromContext(ctx).Errorw("Error reading Redis configuration", zap.Error(err))
-	}
-	// For now just override the previous config.
-	r.numConsumers = redisConfig.NumConsumers
+	} else {
+        // For now just override the previous config.
+        r.numConsumers = redisConfig.NumConsumers
+    }
 }
 
 func (r *Reconciler) updateTLSSecret(ctx context.Context, secret *corev1.Secret) {
 	tlsSecret, err := GetTLSSecret(secret.Data)
 	if err != nil {
 		logging.FromContext(ctx).Errorw("Error reading TLS configuration", zap.Error(err))
+	} else {
+		// For now just override the previous config.
+		r.tlsCert = tlsSecret.TLSCertificate
 	}
-	// For now just override the previous config.
-	r.tlsCert = tlsSecret.TLSCertificate
 }