diff --git a/hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/K8sApi.java b/hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/K8sApi.java
index c204874e..e701d670 100644
--- a/hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/K8sApi.java
+++ b/hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/K8sApi.java
@@ -8,6 +8,9 @@
 import java.util.List;
 import java.util.Map;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import io.kubernetes.client.common.KubernetesListObject;
 import io.kubernetes.client.common.KubernetesObject;
 import io.kubernetes.client.openapi.models.V1OwnerReference;
@@ -19,6 +22,7 @@
 
 
 public class K8sApi<T extends KubernetesObject, U extends KubernetesListObject> implements Api<T> {
+  private final static Logger log = LoggerFactory.getLogger(K8sApi.class);
 
   private final K8sContext context;
   private final K8sApiEndpoint<T, U> endpoint;
@@ -103,6 +107,7 @@ public void create(T obj) throws SQLException {
     context.own(obj);
     KubernetesApiResponse<T> resp = context.<T, U>generic(endpoint).create(obj);
     checkResponse(resp);
+    log.info("Created K8s obj: {}:{}", obj.getKind(), obj.getMetadata().getName());
   }
 
   @Override
@@ -113,6 +118,7 @@ public void delete(T obj) throws SQLException {
     KubernetesApiResponse<T> resp =
         context.<T, U>generic(endpoint).delete(obj.getMetadata().getNamespace(), obj.getMetadata().getName());
     checkResponse(resp);
+    log.info("Deleted K8s obj: {}:{}", obj.getKind(), obj.getMetadata().getName());
   }
 
   @Override
@@ -156,6 +162,7 @@ public void update(T obj) throws SQLException {
       resp = context.<T, U>generic(endpoint).create(obj);
     }
     checkResponse(resp);
+    log.info("Updated K8s obj: {}:{}", obj.getKind(), obj.getMetadata().getName());
   }
 
   public void updateStatus(T obj, Object status) throws SQLException {
@@ -164,6 +171,7 @@ public void updateStatus(T obj, Object status) throws SQLException {
     }
     KubernetesApiResponse<T> resp = context.<T, U>generic(endpoint).updateStatus(obj, x -> status);
     checkResponse(resp);
+    log.info("Updated K8s obj status: {}:{}", obj.getKind(), obj.getMetadata().getName());
   }
 
   private void checkResponse(KubernetesApiResponse<?> resp) throws SQLException {
diff --git a/hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/K8sYamlApi.java b/hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/K8sYamlApi.java
index ee5f01de..241c7e46 100644
--- a/hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/K8sYamlApi.java
+++ b/hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/K8sYamlApi.java
@@ -5,6 +5,9 @@
 import java.util.HashMap;
 import java.util.Map;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import io.kubernetes.client.openapi.ApiException;
 import io.kubernetes.client.util.generic.KubernetesApiResponse;
 import io.kubernetes.client.util.generic.dynamic.DynamicKubernetesObject;
@@ -14,6 +17,7 @@
 
 
 public class K8sYamlApi implements Api<String> {
+  private final static Logger log = LoggerFactory.getLogger(K8sYamlApi.class);
 
   private final K8sContext context;
 
@@ -33,6 +37,7 @@ public void create(String yaml) throws SQLException {
     KubernetesApiResponse<DynamicKubernetesObject> resp =
         context.dynamic(obj.getApiVersion(), K8sUtils.guessPlural(obj)).create(obj);
     checkResponse(yaml, resp);
+    log.info("Created K8s obj: {}:{}", obj.getKind(), obj.getMetadata().getName());
   }
 
   @Override
@@ -42,6 +47,7 @@ public void delete(String yaml) throws SQLException {
         context.dynamic(obj.getApiVersion(), K8sUtils.guessPlural(obj))
             .delete(obj.getMetadata().getNamespace(), obj.getMetadata().getName());
     checkResponse(yaml, resp);
+    log.info("Deleted K8s obj: {}:{}", obj.getKind(), obj.getMetadata().getName());
   }
 
   @Override
@@ -70,6 +76,7 @@ public void update(String yaml) throws SQLException {
       resp = context.dynamic(obj.getApiVersion(), K8sUtils.guessPlural(obj)).create(obj);
     }
     checkResponse(yaml, resp);
+    log.info("Updated K8s obj: {}:{}", obj.getKind(), obj.getMetadata().getName());
   }
 
   private DynamicKubernetesObject objFromYaml(String yaml) {