diff --git a/main.go b/main.go
index 0b5dab7..9af4b0f 100644
--- a/main.go
+++ b/main.go
@@ -184,7 +184,6 @@ func runServer(port string, resourcePath string, awsRegion string, bucketName st
 		go c.Start()
 		defer c.Stop()
 	}
-
 	if err := http.ListenAndServe(":"+port, nil); err != nil {
 		log.Fatalf("Unable to start server: %v", err)
 	}
diff --git a/service/processor.go b/service/processor.go
index 86b67ed..ac87ca0 100644
--- a/service/processor.go
+++ b/service/processor.go
@@ -48,7 +48,7 @@ func (r *S3QProcessor) ProcessMsg(m consumer.Message) {
 	var km KafkaMsg
 	b := []byte(m.Body)
 	if err := json.Unmarshal(b, &km); err != nil {
-		log.Errorf("Could not unmarshall message with ID=%v, error=%v", m.Headers["Message-Id"], err.Error())
+		log.Errorf("Could not unmarshall message with ID=%v, transaction_id=%v, error=%v", m.Headers["Message-Id"], tid, err.Error())
 		return
 	}