diff --git a/pkg/kt/cluster/helper.go b/pkg/kt/cluster/helper.go
index 32387d7..102c81e 100644
--- a/pkg/kt/cluster/helper.go
+++ b/pkg/kt/cluster/helper.go
@@ -33,7 +33,7 @@ func getPodCirds(clientset *kubernetes.Clientset, podCIDR string) (cidrs []strin
 	nodeList, err := clientset.CoreV1().Nodes().List(metav1.ListOptions{})
 
 	if err != nil {
-		log.Printf("Fails to get node info of cluster")
+		log.Error().Msgf("Fails to get node info of cluster")
 		return nil, err
 	}
 
@@ -61,7 +61,7 @@ func getPodCirdByInstance(clientset *kubernetes.Clientset) (samples mapset.Set,
 	log.Info().Msgf("Fail to get pod cidr from node.Spec.PODCIDR, try to get with pod sample")
 	podList, err := clientset.CoreV1().Pods("").List(metav1.ListOptions{})
 	if err != nil {
-		log.Printf("Fails to get service info of cluster")
+		log.Error().Msg("Fails to get service info of cluster")
 		return
 	}
 
diff --git a/pkg/kt/cluster/kubernetes.go b/pkg/kt/cluster/kubernetes.go
index 6bdb1dd..3660b64 100644
--- a/pkg/kt/cluster/kubernetes.go
+++ b/pkg/kt/cluster/kubernetes.go
@@ -18,16 +18,16 @@ import (
 
 // Scale scale deployment to
 func (k *Kubernetes) Scale(deployment *appV1.Deployment, replicas *int32) (err error) {
-	log.Printf("scale deployment %s to %d\n", deployment.GetObjectMeta().GetName(), *replicas)
+	log.Info().Msgf("scale deployment %s to %d\n", deployment.GetObjectMeta().GetName(), *replicas)
 	client := k.Clientset.AppsV1().Deployments(deployment.GetObjectMeta().GetNamespace())
 	deployment.Spec.Replicas = replicas
 
 	d, err := client.Update(deployment)
 	if err != nil {
-		log.Printf("%s Fails scale deployment %s to %d\n", err.Error(), deployment.GetObjectMeta().GetName(), *replicas)
+		log.Error().Msgf("%s Fails scale deployment %s to %d\n", err.Error(), deployment.GetObjectMeta().GetName(), *replicas)
 		return
 	}
-	log.Printf(" * %s (%d replicas) success", d.Name, *d.Spec.Replicas)
+	log.Info().Msgf(" * %s (%d replicas) success", d.Name, *d.Spec.Replicas)
 	return
 }
 
diff --git a/pkg/kt/connect/inbound.go b/pkg/kt/connect/inbound.go
index 32d6f20..a96ad01 100644
--- a/pkg/kt/connect/inbound.go
+++ b/pkg/kt/connect/inbound.go
@@ -33,7 +33,7 @@ func (s *Shadow) Inbound(exposePort, podName, remoteIP string) (err error) {
 	if err != nil {
 		return
 	}
-	log.Printf("SSH Remote port-forward POD %s 22 to 127.0.0.1:%d starting\n", remoteIP, localSSHPort)
+	log.Info().Msgf("SSH Remote port-forward POD %s 22 to 127.0.0.1:%d starting\n", remoteIP, localSSHPort)
 	localPort := exposePort
 	remotePort := exposePort
 	ports := strings.SplitN(exposePort, ":", 2)
diff --git a/pkg/kt/exec/run.go b/pkg/kt/exec/run.go
index 54cbeb4..b0e102a 100644
--- a/pkg/kt/exec/run.go
+++ b/pkg/kt/exec/run.go
@@ -22,7 +22,7 @@ func BackgroundRun(cmd *exec.Cmd, name string, debug bool) (err error) {
 	runCmd(cmd, name, debug)
 	go func() {
 		err = cmd.Wait()
-		log.Printf("%s finished", name)
+		log.Info().Msgf("%s finished", name)
 	}()
 	return
 }
@@ -52,6 +52,6 @@ func runCmd(cmd *exec.Cmd, name string, debug bool) (err error) {
 
 	time.Sleep(time.Duration(2) * time.Second)
 	pid := cmd.Process.Pid
-	log.Printf("%s start at pid: %d", name, pid)
+	log.Info().Msgf("%s start at pid: %d", name, pid)
 	return
 }
diff --git a/pkg/kt/util/system.go b/pkg/kt/util/system.go
index 37177dc..d61f6f7 100644
--- a/pkg/kt/util/system.go
+++ b/pkg/kt/util/system.go
@@ -51,7 +51,7 @@ func init() {
 func PrepareSSHPrivateKey() (err error) {
 	err = ioutil.WriteFile(PrivateKeyPath(), pk, 400)
 	if err != nil {
-		log.Printf("Fails create temp ssh private key")
+		log.Error().Msgf("Fails create temp ssh private key")
 	}
 	return
 }