Merge pull request #5 from kayac/feature/add-error-handling

Feature/add error handling

encoder.go

@@ -2,7 +2,7 @@ package router
 
 import (
 	"encoding/json"
-	"log"
+	"fmt"
 )
 
 // LF represents LineFeed \n
@@ -44,8 +44,7 @@ func (e *jsonEncoder) Encode(rec record, _ []byte) error {
 
 	bytes, err := json.Marshal(rec)
 	if err != nil {
-		log.Println("[warn] failed to generate json record", err)
-		return err
+		return fmt.Errorf("json marshal: %w", err)
 	}
 	if _, err := e.body.Write(bytes); err != nil {
 		return err

router.go

@@ -180,7 +180,10 @@ func (r *Router) route(src io.Reader, s3url string) (map[destination]buffer, err
 			}
 			enc = r.option.newEncoder(body)
 		}
-		enc.Encode(rec, recordBytes)
+		if err := enc.Encode(rec, recordBytes); err != nil {
+			log.Printf("[warn] failed to encode %s record: %v\n", err, rec)
+			continue
+		}
 		encs[d] = enc
 	}
 	if err := scanner.Err(); err != nil {