diff --git a/connector/collector/docker_logs.go b/connector/collector/docker_logs.go
index f350d36..3f1e40f 100644
--- a/connector/collector/docker_logs.go
+++ b/connector/collector/docker_logs.go
@@ -58,6 +58,7 @@ func (l *DockerLogs) Stream() chan models.Log {
 		if err != nil {
 			log.Errorf("error reading container logs: %s", err)
 		}
+		log.Infof("log reader stopped for container: %s", l.id)
 	}()
 
 	go func() {
@@ -67,6 +68,7 @@ func (l *DockerLogs) Stream() chan models.Log {
 		}
 	}()
 
+	log.Infof("log reader started for container: %s", l.id)
 	return logCh
 }