Kinesis output shouldn't return an error for no reason

This commit is contained in:
Cameron Sparr 2016-01-22 17:26:48 -07:00
parent 5349a3b6d1
commit 3da390682d
1 changed files with 1 additions and 2 deletions

View File

@ -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) {