This is a small Go library and unix command for streaming to an Amazon Kinesis stream.
$ go get -u github.com/remind101/kinesis
Stream a file to a kinesis stream.
$ cat /var/log/syslog | kinesis <stream>
Stream to a particular partition key.
$ cat /var/log/syslog | kinesis <stream> -p <partitionKey>
The Go library exposes an io.Writer implementation that writes to an Amazon Kinesis stream.
import "github.com/remind101/kinesis/kinesis"
stream = bufio.NewWriter(kinesis.NewDefaultWriter("streamName", "partitionKey"))
io.Copy(stream, os.Stdin)