diff --git a/plugins/outputs/kinesis/kinesis.go b/plugins/outputs/kinesis/kinesis.go
index f04f1c7c6..23ca03c5e 100644
--- a/plugins/outputs/kinesis/kinesis.go
+++ b/plugins/outputs/kinesis/kinesis.go
@@ -1,7 +1,6 @@
 package kinesis
 
 import (
-	"errors"
 	"fmt"
 	"log"
 	"os"
@@ -101,7 +100,7 @@ func (k *KinesisOutput) Connect() error {
 }
 
 func (k *KinesisOutput) Close() error {
-	return errors.New("Error")
+	return nil
 }
 
 func FormatMetric(k *KinesisOutput, point *client.Point) (string, error) {