Skip to content

Instantly share code, notes, and snippets.

@jriquelme

jriquelme/kstest.go

Created January 20, 2016 14:43
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save jriquelme/144816586e3f421d00af to your computer and use it in GitHub Desktop.
Save jriquelme/144816586e3f421d00af to your computer and use it in GitHub Desktop.
Download ZIP
random errors in kinesalite using NextShardIterator
Raw
kstest.go
package main
import (
"fmt"
"log"
"strconv"
"sync"
"time"
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/aws/session"
"github.com/aws/aws-sdk-go/service/kinesis"
"github.com/davecgh/go-spew/spew"
)
var useKinesalite = true
func main() {
stream := "teststream"
var k *kinesis.Kinesis
if useKinesalite {
stream = fmt.Sprintf("teststream_%d", time.Now().Unix())
cfg := aws.NewConfig().WithEndpoint("http://127.0.0.1:4567").WithRegion("us-east-1")
k = kinesis.New(session.New(), cfg)
createStream(stream, 8, k)
} else {
k = kinesis.New(session.New())
}
// put records
n := 100
for i := 0; i < n; i++ {
input := &kinesis.PutRecordInput{
Data: []byte(fmt.Sprintf("record %d", i)),
PartitionKey: aws.String(strconv.Itoa(i)),
StreamName: aws.String(stream),
}
_, putErr := k.PutRecord(input)
if putErr != nil {
panic(putErr)
}
}
log.Print("frames sent")
// check
desc, descErr := k.DescribeStream(&kinesis.DescribeStreamInput{
StreamName: aws.String(stream),
})
if descErr != nil {
panic(descErr)
}
if *desc.StreamDescription.StreamStatus != "ACTIVE" {
spew.Dump(desc.StreamDescription)
panic("invalid stream status")
}
// read from each shard
msgs := make(chan []byte, n)
var wg sync.WaitGroup
for _, shard := range desc.StreamDescription.Shards {
wg.Add(1)
// one go routine per shard
go func(shardID *string) {
defer wg.Done()
log.Printf("reading from shard %s", *shardID)
itOut, itErr := k.GetShardIterator(&kinesis.GetShardIteratorInput{
ShardId: shardID,
ShardIteratorType: aws.String("TRIM_HORIZON"),
StreamName: aws.String(stream),
})
if itErr != nil {
panic(itErr)
}
// get records...
shardIt := itOut.ShardIterator
for {
getOut, getErr := k.GetRecords(&kinesis.GetRecordsInput{
Limit: aws.Int64(10),
ShardIterator: shardIt,
})
if getErr != nil {
panic(getErr)
}
log.Printf("%d records read from shard %s with iterator %s (MillisBehindLatest=%d)", len(getOut.Records), *shardID, *shardIt, *getOut.MillisBehindLatest)
for _, r := range getOut.Records {
msgs <- r.Data
}
// stop if we got nothing and MillisBehindLatest is zero...
if len(getOut.Records) == 0 && *getOut.MillisBehindLatest == 0 {
log.Printf("done with shard %s", *shardID)
return
}
shardIt = getOut.NextShardIterator
// or if the shard was closed
if shardIt == nil {
log.Printf("done with shard %s, closed", *shardID)
return
}
}
}(shard.ShardId)
}
wg.Wait()
close(msgs)
log.Print("records fetched")
// print and count messages
c := 0
for msg := range msgs {
fmt.Sprintf("<- %s", msg)
c++
}
log.Printf("%d messages", c)
}
func createStream(name string, shards int64, k *kinesis.Kinesis) {
log.Printf("creating stream %s", name)
_, err := k.CreateStream(&kinesis.CreateStreamInput{
ShardCount: aws.Int64(shards),
StreamName: aws.String(name),
})
if err != nil {
panic(err)
}
statusloop:
for {
output, err := k.DescribeStream(&kinesis.DescribeStreamInput{
StreamName: aws.String(name),
})
if err != nil {
panic(err)
}
status := *(output.StreamDescription.StreamStatus)
switch status {
case "CREATING":
case "ACTIVE":
break statusloop
default:
panic(fmt.Sprintf("invalid status %s", status))
}
}
log.Printf("stream %s created", name)
}
Raw
kstest_err.txt
2016/01/20 11:25:35 creating stream teststream_1453299935
2016/01/20 11:25:36 stream teststream_1453299935 created
2016/01/20 11:25:36 frames sent
2016/01/20 11:25:36 reading from shard shardId-000000000007
2016/01/20 11:25:36 reading from shard shardId-000000000003
2016/01/20 11:25:36 reading from shard shardId-000000000001
2016/01/20 11:25:36 reading from shard shardId-000000000005
2016/01/20 11:25:36 reading from shard shardId-000000000006
2016/01/20 11:25:36 reading from shard shardId-000000000000
2016/01/20 11:25:36 reading from shard shardId-000000000002
2016/01/20 11:25:36 reading from shard shardId-000000000004
2016/01/20 11:25:36 5 records read from shard shardId-000000000002 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdAp4vqvDPdhdfCOQO9tv23ocqtxsPB/qO7BlgjsSx+IHkbyzVTgAT81SPS6H4GALMbDwABc4I+8gnK6waK48MYpXRsxLzhJ8VwgALmm/YQW+CnKZer3VY9uL+xle+g1zf5NgTM8vgQwrA8FaL18L0k9Z (MillisBehindLatest=0)
2016/01/20 11:25:36 0 records read from shard shardId-000000000002 with iterator AAAAAAAAAAEFnRepSIIy7CmtuBJxgJ9sacV1NKlC/7njtoXJ1crOM0Y1xGvx2x4EvEzKYuqsFVo3cM6xwywpuUtMN0LCTLCP2vImoWFwrTtI7FiGOprEBVRWarRIRl2GfaJ/FedxF1fZNDum0jdWpc0F0yDoxCIXKOc1yFydO7ksJaqws34pNt8i4X7V2ae2YX7AF8tGOIjvGJBj6ZxflEyJ42FK8sVH (MillisBehindLatest=0)
2016/01/20 11:25:36 done with shard shardId-000000000002
2016/01/20 11:25:36 10 records read from shard shardId-000000000003 with iterator AAAAAAAAAAHRAu2VrJTmHaa46zTaq7zHqC+oC7X5+Yd/iGpBQcEDWTe35B02buUNwqNBixxbwjQe3CcxqSRTC3JMB2tFvSc6OcBKC5U08x+Xe+woq9nhUDvyCCbyDpj7cjq0TU4tP5sxD+FFQMJdS+iVIvT7dF+VZDqceQRz7ZTUdQvr5HeEfmg17SYFam/ER5FTrUtEnuZfvB6TB9OJOWCMT2RipDLH (MillisBehindLatest=0)
2016/01/20 11:25:36 10 records read from shard shardId-000000000005 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdAoc3Yh1p6B02Hpy+NpZMQqZk3RO3UPzI6/agokI2ghL3uVtg/c2tlx+5DKDF+bMYRoB4gyMxv3W0H+ZVW0PC/Ush1dyQSb8vJb0Bg/7vsQhP0x/XIjLsNV0BXrlOc0NGFYuSH0/N8krTE+VM4KwYvAd (MillisBehindLatest=0)
2016/01/20 11:25:36 10 records read from shard shardId-000000000007 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdAqdOkunoisyMwd9wkleRuRBLNDuTD+4te8cOs+yb2nmpS2JMGlio81FJbuS1L7loAofBF+Hd6ofSGoJBQ+xJ1KDwntKh18eFT4+aE6QJRXpV142s+zUfM7kxK6V3zZ9sh2/I9WZ9VjqlbF+GiCnIqfs (MillisBehindLatest=0)
2016/01/20 11:25:36 10 records read from shard shardId-000000000001 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdApKcsw6+QKb6RoJfJCZkWXtaMuvUL4PX0RfFJd4fK9NGdWwmWFG+zatoiLu00tqR/h5de8AjnSuMSvttBd2jfrpa8X6Sxi4u2RXDZBsw7oDNigppmNO3Dev4WuHUnatM1/ymfBddeL0Y3CEO/XuWpq9 (MillisBehindLatest=0)
2016/01/20 11:25:36 10 records read from shard shardId-000000000006 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdApKFJjcXX8eEEJaGFTRn1V+9Yyy+DxcCO+hzEXWq/70IdHqM/Ix2iMatggYL1TQ+H66LQgG6Yh1+84/N5Atc3FQyAEndmwBvE3lfbSx9MSC7MMlXGsqv8UZntUoQC5JKj1dhyIPN/yiZuFQJq63OAiI (MillisBehindLatest=0)
2016/01/20 11:25:36 10 records read from shard shardId-000000000000 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdArSdpATBn6KpYERaVzRNZHu8muBn2t69UVfglsboJMr9XZHx6+BjmLjlbCi1mvQevXvevSrEaGUtBb5j0BD2j48jA+VAjcNDmCJY0AGlrMY7agKBjSUqy8e+QYzL6i0DRfHz5TIvB2vFhpUiJ8tDWJG (MillisBehindLatest=0)
2016/01/20 11:25:36 10 records read from shard shardId-000000000004 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdAohbOHNhAB+/XIGgFGTKjEPr5ipBoPVsFns7UIVPnlZxwAKUKFXCQLhFS17TMgkQPbWPQo2XFx/IdF77s+koeNOUO+Gc7w4SvzKrJi8CN9ryzDMNAOndWbSjGjuy0DHS3LSBZhOdeURnojZTZd3ecmz (MillisBehindLatest=0)
2016/01/20 11:25:36 1 records read from shard shardId-000000000005 with iterator AAAAAAAAAAHNpnN3rz+7nkQHJL3DRJVDYRtp4wuNKGlwgQrdN+lB4GuzgUHDC4wwYLBVpBbm54uKHgyjYBn3ekZUcVeFftIOgID+YwWpJyWbWOQbHkiALo0XXFtFX0bEe0+S1V43n3d5cJSDv7xpAQNpUnDSg4V9Y7Q75tDZiatZUfJe7yau2uQdSR3mEABh8cDOHKjaSSCownU+mvDAl3wxotIUm7Le (MillisBehindLatest=0)
2016/01/20 11:25:36 2 records read from shard shardId-000000000000 with iterator AAAAAAAAAAHmNu/M6jRPf929Ab4YwbaxUdXCErCqp4rJITq6Zf7Uz1bBxAzLVVoQkVNBHjT+fClmtpHWZMhzRHM30f8c5dalPrSi72S5XR/aDIPfP97w8yrrPGLc6WkK7eZCmdyXOacDVoaM2LCnDn2S1M/ws2O5V6HV6JguLrxpm/S4lA/ajmB4hTNca/citTJJ6WggwDI5KCYyeIMXQyTelR/jP9EV (MillisBehindLatest=0)
panic: InvalidArgumentException: Invalid ShardIterator.
status code: 400, request id: ac2e4cb0-bf81-11e5-813b-3d874e374272
goroutine 25 [running]:
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc820135270)
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:82 +0x39d
created by main.main
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7
goroutine 1 [semacquire]:
sync.runtime_Semacquire(0xc8201357bc)
/usr/local/go/src/runtime/sema.go:43 +0x26
sync.(*WaitGroup).Wait(0xc8201357b0)
/usr/local/go/src/sync/waitgroup.go:126 +0xb4
main.main()
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:103 +0xafa
goroutine 17 [syscall, locked to thread]:
runtime.goexit()
/usr/local/go/src/runtime/asm_amd64.s:1721 +0x1
goroutine 20 [select]:
net/http.(*persistConn).roundTrip(0xc820172000, 0xc82044e140, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1164 +0xb0d
net/http.(*Transport).RoundTrip(0xc820086090, 0xc82021b5e0, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:235 +0x530
net/http.send(0xc82021b5e0, 0x7f6967af74d8, 0xc820086090, 0xc820445140, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:220 +0x52c
net/http.(*Client).send(0x9f94c0, 0xc82021b5e0, 0x16, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:143 +0x15a
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc82021b5e0, 0x8be950, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:380 +0xbc0
net/http.(*Client).Do(0x9f94c0, 0xc82021b5e0, 0x14, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:178 +0x188
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820343600)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc820343730, 0xc820343600)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820343600, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc820444d80, 0xc820421488, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc8201347d0)
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350
created by main.main
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7
goroutine 18 [IO wait]:
net.runtime_pollWait(0x7f6967af89f8, 0x72, 0xc82000a200)
/usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc820061cd0, 0x72, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc820061cd0, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).Read(0xc820061c70, 0xc8200d0000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200)
/usr/local/go/src/net/fd_unix.go:232 +0x23a
net.(*conn).Read(0xc8200ca000, 0xc8200d0000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:172 +0xe4
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc8200ca000, 0xc8200c4058, 0xc8200d0000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1370 +0x67
net/http.(*noteEOFReader).Read(0xc8200c6040, 0xc8200d0000, 0x1000, 0x1000, 0xc82021c310, 0x0, 0x0)
<autogenerated>:126 +0xd0
bufio.(*Reader).fill(0xc8200ce000)
/usr/local/go/src/bufio/bufio.go:97 +0x1e9
bufio.(*Reader).Peek(0xc8200ce000, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
/usr/local/go/src/bufio/bufio.go:132 +0xcc
net/http.(*persistConn).readLoop(0xc8200c4000)
/usr/local/go/src/net/http/transport.go:876 +0xf7
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:685 +0xc78
goroutine 19 [select]:
net/http.(*persistConn).writeLoop(0xc8200c4000)
/usr/local/go/src/net/http/transport.go:1009 +0x40c
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:686 +0xc9d
goroutine 21 [runnable]:
net/http.(*persistConn).roundTrip(0xc820394000, 0xc8204320f0, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1164 +0xb0d
net/http.(*Transport).RoundTrip(0xc820086090, 0xc82021b260, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:235 +0x530
net/http.send(0xc82021b260, 0x7f6967af74d8, 0xc820086090, 0xc8201bde80, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:220 +0x52c
net/http.(*Client).send(0x9f94c0, 0xc82021b260, 0x16, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:143 +0x15a
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc82021b260, 0x8be950, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:380 +0xbc0
net/http.(*Client).Do(0x9f94c0, 0xc82021b260, 0x14, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:178 +0x188
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820343080)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc8203431b0, 0xc820343080)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820343080, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc8201bdac0, 0xc820420948, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc8201349f0)
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350
created by main.main
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7
goroutine 23 [select]:
net/http.(*persistConn).roundTrip(0xc8200c4000, 0xc8201d4520, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1164 +0xb0d
net/http.(*Transport).RoundTrip(0xc820086090, 0xc82036c460, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:235 +0x530
net/http.send(0xc82036c460, 0x7f6967af74d8, 0xc820086090, 0xc820353a00, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:220 +0x52c
net/http.(*Client).send(0x9f94c0, 0xc82036c460, 0x16, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:143 +0x15a
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc82036c460, 0x8be950, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:380 +0xbc0
net/http.(*Client).Do(0x9f94c0, 0xc82036c460, 0x14, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:178 +0x188
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820370840)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc820370970, 0xc820370840)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820370840, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc820353640, 0xc820358f48, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc820134e30)
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350
created by main.main
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7
goroutine 24 [select]:
net/http.(*persistConn).roundTrip(0xc8203920b0, 0xc820433790, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1164 +0xb0d
net/http.(*Transport).RoundTrip(0xc820086090, 0xc82021b420, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:235 +0x530
net/http.send(0xc82021b420, 0x7f6967af74d8, 0xc820086090, 0xc820444a60, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:220 +0x52c
net/http.(*Client).send(0x9f94c0, 0xc82021b420, 0x16, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:143 +0x15a
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc82021b420, 0x8be950, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:380 +0xbc0
net/http.(*Client).Do(0x9f94c0, 0xc82021b420, 0x14, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:178 +0x188
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820343340)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc820343470, 0xc820343340)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820343340, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc8204446a0, 0xc820421108, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc820135050)
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350
created by main.main
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7
goroutine 26 [select]:
net/http.(*persistConn).roundTrip(0xc820152000, 0xc8201d5bc0, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1164 +0xb0d
net/http.(*Transport).RoundTrip(0xc820086090, 0xc82036c620, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:235 +0x530
net/http.send(0xc82036c620, 0x7f6967af74d8, 0xc820086090, 0xc8204345e0, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:220 +0x52c
net/http.(*Client).send(0x9f94c0, 0xc82036c620, 0x16, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:143 +0x15a
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc82036c620, 0x8be950, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:380 +0xbc0
net/http.(*Client).Do(0x9f94c0, 0xc82036c620, 0x14, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:178 +0x188
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820370b00)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc820370c30, 0xc820370b00)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820370b00, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc820434220, 0xc820359708, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc820135490)
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350
created by main.main
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7
goroutine 27 [select]:
net/http.(*persistConn).roundTrip(0xc8200c40b0, 0xc8201c9950, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1164 +0xb0d
net/http.(*Transport).RoundTrip(0xc820086090, 0xc8203788c0, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:235 +0x530
net/http.send(0xc8203788c0, 0x7f6967af74d8, 0xc820086090, 0xc8204287e0, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:220 +0x52c
net/http.(*Client).send(0x9f94c0, 0xc8203788c0, 0x16, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:143 +0x15a
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc8203788c0, 0x8be950, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:380 +0xbc0
net/http.(*Client).Do(0x9f94c0, 0xc8203788c0, 0x14, 0x0, 0x0)
/usr/local/go/src/net/http/client.go:178 +0x188
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820388dc0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc820388ef0, 0xc820388dc0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820388dc0, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc820428420, 0xc8203677c8, 0x0, 0x0)
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc8201356b0)
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350
created by main.main
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7
goroutine 35 [IO wait]:
net.runtime_pollWait(0x7f6967af8938, 0x72, 0xc82000a200)
/usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc820376220, 0x72, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc820376220, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).Read(0xc8203761c0, 0xc82015c000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200)
/usr/local/go/src/net/fd_unix.go:232 +0x23a
net.(*conn).Read(0xc820034020, 0xc82015c000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:172 +0xe4
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc820034020, 0xc820392058, 0xc82015c000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1370 +0x67
net/http.(*noteEOFReader).Read(0xc820352460, 0xc82015c000, 0x1000, 0x1000, 0xc820345030, 0x0, 0x0)
<autogenerated>:126 +0xd0
bufio.(*Reader).fill(0xc82037a7e0)
/usr/local/go/src/bufio/bufio.go:97 +0x1e9
bufio.(*Reader).Peek(0xc82037a7e0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
/usr/local/go/src/bufio/bufio.go:132 +0xcc
net/http.(*persistConn).readLoop(0xc820392000)
/usr/local/go/src/net/http/transport.go:876 +0xf7
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:685 +0xc78
goroutine 29 [IO wait]:
net.runtime_pollWait(0x7f6967af8878, 0x72, 0xc82000a200)
/usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc820101640, 0x72, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc820101640, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).Read(0xc8201015e0, 0xc82015e000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200)
/usr/local/go/src/net/fd_unix.go:232 +0x23a
net.(*conn).Read(0xc82021c2c8, 0xc82015e000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:172 +0xe4
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc82021c2c8, 0xc8200c4108, 0xc82015e000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1370 +0x67
net/http.(*noteEOFReader).Read(0xc82012d200, 0xc82015e000, 0x1000, 0x1000, 0xc820345030, 0x0, 0x0)
<autogenerated>:126 +0xd0
bufio.(*Reader).fill(0xc82037c3c0)
/usr/local/go/src/bufio/bufio.go:97 +0x1e9
bufio.(*Reader).Peek(0xc82037c3c0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
/usr/local/go/src/bufio/bufio.go:132 +0xcc
net/http.(*persistConn).readLoop(0xc8200c40b0)
/usr/local/go/src/net/http/transport.go:876 +0xf7
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:685 +0xc78
goroutine 36 [select]:
net/http.(*persistConn).writeLoop(0xc820392000)
/usr/local/go/src/net/http/transport.go:1009 +0x40c
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:686 +0xc9d
goroutine 67 [IO wait]:
net.runtime_pollWait(0x7f6967af86f8, 0x72, 0xc82000a200)
/usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc82038c220, 0x72, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc82038c220, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).Read(0xc82038c1c0, 0xc82016e000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200)
/usr/local/go/src/net/fd_unix.go:232 +0x23a
net.(*conn).Read(0xc82014e008, 0xc82016e000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:172 +0xe4
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc82014e008, 0xc820152058, 0xc82016e000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1370 +0x67
net/http.(*noteEOFReader).Read(0xc820364460, 0xc82016e000, 0x1000, 0x1000, 0xc820345030, 0x0, 0x0)
<autogenerated>:126 +0xd0
bufio.(*Reader).fill(0xc82038e7e0)
/usr/local/go/src/bufio/bufio.go:97 +0x1e9
bufio.(*Reader).Peek(0xc82038e7e0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
/usr/local/go/src/bufio/bufio.go:132 +0xcc
net/http.(*persistConn).readLoop(0xc820152000)
/usr/local/go/src/net/http/transport.go:876 +0xf7
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:685 +0xc78
goroutine 68 [select]:
net/http.(*persistConn).writeLoop(0xc820152000)
/usr/local/go/src/net/http/transport.go:1009 +0x40c
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:686 +0xc9d
goroutine 30 [select]:
net/http.(*persistConn).writeLoop(0xc8200c40b0)
/usr/local/go/src/net/http/transport.go:1009 +0x40c
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:686 +0xc9d
goroutine 82 [select]:
net/http.(*persistConn).readLoop(0xc820394000)
/usr/local/go/src/net/http/transport.go:976 +0xac7
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:685 +0xc78
goroutine 83 [select]:
net/http.(*persistConn).writeLoop(0xc820394000)
/usr/local/go/src/net/http/transport.go:1009 +0x40c
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:686 +0xc9d
goroutine 98 [IO wait]:
net.runtime_pollWait(0x7f6967af8638, 0x72, 0xc82000a200)
/usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc820201f00, 0x72, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc820201f00, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).Read(0xc820201ea0, 0xc82019e000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200)
/usr/local/go/src/net/fd_unix.go:232 +0x23a
net.(*conn).Read(0xc82032e2e0, 0xc82019e000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:172 +0xe4
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc82032e2e0, 0xc820172058, 0xc82019e000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1370 +0x67
net/http.(*noteEOFReader).Read(0xc82012af00, 0xc82019e000, 0x1000, 0x1000, 0xc820345030, 0x0, 0x0)
<autogenerated>:126 +0xd0
bufio.(*Reader).fill(0xc82015a1e0)
/usr/local/go/src/bufio/bufio.go:97 +0x1e9
bufio.(*Reader).Peek(0xc82015a1e0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
/usr/local/go/src/bufio/bufio.go:132 +0xcc
net/http.(*persistConn).readLoop(0xc820172000)
/usr/local/go/src/net/http/transport.go:876 +0xf7
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:685 +0xc78
goroutine 99 [select]:
net/http.(*persistConn).writeLoop(0xc820172000)
/usr/local/go/src/net/http/transport.go:1009 +0x40c
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:686 +0xc9d
goroutine 52 [IO wait]:
net.runtime_pollWait(0x7f6967af8578, 0x72, 0xc82000a200)
/usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc8204d46f0, 0x72, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc8204d46f0, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).Read(0xc8204d4690, 0xc8201a0000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200)
/usr/local/go/src/net/fd_unix.go:232 +0x23a
net.(*conn).Read(0xc8200ca028, 0xc8201a0000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:172 +0xe4
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc8200ca028, 0xc820394108, 0xc8201a0000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1370 +0x67
net/http.(*noteEOFReader).Read(0xc82000f960, 0xc8201a0000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
<autogenerated>:126 +0xd0
bufio.(*Reader).fill(0xc8200cf800)
/usr/local/go/src/bufio/bufio.go:97 +0x1e9
bufio.(*Reader).Peek(0xc8200cf800, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
/usr/local/go/src/bufio/bufio.go:132 +0xcc
net/http.(*persistConn).readLoop(0xc8203940b0)
/usr/local/go/src/net/http/transport.go:876 +0xf7
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:685 +0xc78
goroutine 53 [select]:
net/http.(*persistConn).writeLoop(0xc8203940b0)
/usr/local/go/src/net/http/transport.go:1009 +0x40c
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:686 +0xc9d
goroutine 38 [IO wait]:
net.runtime_pollWait(0x7f6967af84b8, 0x72, 0xc82000a200)
/usr/local/go/src/runtime/netpoll.go:157 +0x60
net.(*pollDesc).Wait(0xc8203764c0, 0x72, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a
net.(*pollDesc).WaitRead(0xc8203764c0, 0x0, 0x0)
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36
net.(*netFD).Read(0xc820376460, 0xc8201aa000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200)
/usr/local/go/src/net/fd_unix.go:232 +0x23a
net.(*conn).Read(0xc820034030, 0xc8201aa000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:172 +0xe4
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc820034030, 0xc820392108, 0xc8201aa000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/http/transport.go:1370 +0x67
net/http.(*noteEOFReader).Read(0xc820352940, 0xc8201aa000, 0x1000, 0x1000, 0xc820345030, 0x0, 0x0)
<autogenerated>:126 +0xd0
bufio.(*Reader).fill(0xc82037b140)
/usr/local/go/src/bufio/bufio.go:97 +0x1e9
bufio.(*Reader).Peek(0xc82037b140, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
/usr/local/go/src/bufio/bufio.go:132 +0xcc
net/http.(*persistConn).readLoop(0xc8203920b0)
/usr/local/go/src/net/http/transport.go:876 +0xf7
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:685 +0xc78
goroutine 39 [select]:
net/http.(*persistConn).writeLoop(0xc8203920b0)
/usr/local/go/src/net/http/transport.go:1009 +0x40c
created by net/http.(*Transport).dialConn
/usr/local/go/src/net/http/transport.go:686 +0xc9d
exit status 2
Raw
kstest_ok.txt
2016/01/20 11:25:23 creating stream teststream_1453299923
2016/01/20 11:25:23 stream teststream_1453299923 created
2016/01/20 11:25:23 frames sent
2016/01/20 11:25:23 reading from shard shardId-000000000007
2016/01/20 11:25:23 reading from shard shardId-000000000000
2016/01/20 11:25:23 reading from shard shardId-000000000003
2016/01/20 11:25:23 reading from shard shardId-000000000005
2016/01/20 11:25:23 reading from shard shardId-000000000004
2016/01/20 11:25:23 reading from shard shardId-000000000001
2016/01/20 11:25:23 reading from shard shardId-000000000006
2016/01/20 11:25:23 reading from shard shardId-000000000002
2016/01/20 11:25:23 5 records read from shard shardId-000000000002 with iterator AAAAAAAAAAGVTG2xIRBLGw4zEybQRl9TpIuQJJ6QeW6HKVn0OKJzJDdvErSEYlV6LKTFVQKLJtAn6zCe8fZPO6ZgAZU4h+hwfQKG7NZ0N1i8ry7RMcZHZ3nxs14cofZ1n4ghaZMOhZ/3SbmXM5NXARWQzQsVWjxZ3gcPB91Iu2SCzIQFAV2IzWfHcJUhRGk82UM2VUrw8ysNuINQROkVaR0mUblhvvBX (MillisBehindLatest=0)
2016/01/20 11:25:23 10 records read from shard shardId-000000000007 with iterator AAAAAAAAAAHMOFsPspRjUZzPbOpfdX11kGdYqq7Brcm0w7z9syu797Wfotj6PiZQ8FrtGsvkj5dMofEFiBGmehDC68nfx88i1L9TPBTPAspz684XMqcTuM3H6zDcbbwH7MIaOLZvl5EX/Ok9aWL1DM60U0yibCMOmtq1pQFApWTt+5lNPNOfoRhN/XbiereDFkLdBglEJlvBE5kmA4+AG383Yo68jswz (MillisBehindLatest=0)
2016/01/20 11:25:23 0 records read from shard shardId-000000000002 with iterator AAAAAAAAAAGZcW2mz2zp9WyY0y9sCnNmQwqXKSoyRQGJehD1Ld3SDNYPtJ2i9gORY1eRiRbfg5u/0B5Cc/Dhs578ySebSikw4RjH2ali4CYbdS5AzCS1wvDz4ilhBstyBXyuPC92rRJiGqWeisUrghOP8t8177HC00zVRrAyIID6W6VWROrpxOggY3jWbOUKCzFcA65hdfHYYCaQudjL74E03yK27WUt (MillisBehindLatest=0)
2016/01/20 11:25:23 done with shard shardId-000000000002
2016/01/20 11:25:23 10 records read from shard shardId-000000000000 with iterator AAAAAAAAAAFwCHhWqfTUNikGLIP4x/hADn6az0AbEVBZenwOUJ0GyDV6qW9PM4ujfCNQCEiBwkwi3jm+piEPASU+5FNf+oTI7B7URk929NYBKfYz0KT3Qb7Dzs8Q32j17JvhUFBkLwECSPyB1+bW6lAydpwhKndavQsDagq4cIGkvAXedknozT7J8rrr+3/7RuxSw+VR3kQmLVsI9XQtY5lY+yvUXGGM (MillisBehindLatest=0)
2016/01/20 11:25:23 10 records read from shard shardId-000000000003 with iterator AAAAAAAAAAFwCHhWqfTUNikGLIP4x/hADn6az0AbEVBZenwOUJ0GyDV6qW9PM4ujfCNQCEiBwkxvIzkpEVo6lQScuxACQ2FKh2qIIegy/VQZ3Da785IGdE4Ex+uw0f5ISdkWRv0j9mdDvFY2qccl8u8kAQiNIDu1uFG86LWvkYeE3vHv9g0ZgqYBZwM1uD74Thbu8VKVgu5yAe6MQb93p3eYA6YEkK0v (MillisBehindLatest=0)
2016/01/20 11:25:23 10 records read from shard shardId-000000000005 with iterator AAAAAAAAAAFwCHhWqfTUNikGLIP4x/hADn6az0AbEVBZenwOUJ0GyDV6qW9PM4ujfCNQCEiBwkx5zO0ehOdE9KXOohP3seQhUWGWaqoOk49sh0dBJuZlnGujHIUpN+ANTlG5mAy8Vlyw6715MdvsMk9rcY8h0O3NFVd5ZW6Xg98KaVkZqIr6+wU9GOzzy1oBFpd4C8JroiJcUO4Wit5JcoBJmk2XmLSZ (MillisBehindLatest=0)
2016/01/20 11:25:23 10 records read from shard shardId-000000000004 with iterator AAAAAAAAAAFwCHhWqfTUNikGLIP4x/hADn6az0AbEVBZenwOUJ0GyDV6qW9PM4ujfCNQCEiBwkxSWEkZZ0Y/KRtEZwZF6QJioxof/BP8pWVPs+/l/w+RFTE0O6etRhwS/bkFblzb7+49zVdGl9Xbc2IZftOV1SKcudm4Ox0AzCMhwCLE6tvgZ28YFcGsG5QRxq1yQnwOzPdzNVPIGwvaHFTVlnBoR5zR (MillisBehindLatest=0)
2016/01/20 11:25:23 10 records read from shard shardId-000000000001 with iterator AAAAAAAAAAFwCHhWqfTUNikGLIP4x/hADn6az0AbEVBZenwOUJ0GyDV6qW9PM4ujfCNQCEiBwkxgT6kFeQzCDiCdMjMLl0wfD/AiA+9HmGi1UuxQ4qFHeuAipI5rsej3bAVNSQE3j7GzS74JRukmVdhViJxeV9y5tkOrrWxPw4Rk1Qs8DGhgEJTPDPvMKTtr/Pyu4DzzI/X8J0m/41alOE+NGEb2ZXww (MillisBehindLatest=0)
2016/01/20 11:25:23 10 records read from shard shardId-000000000006 with iterator AAAAAAAAAAGVTG2xIRBLGw4zEybQRl9TpIuQJJ6QeW6HKVn0OKJzJDdvErSEYlV6LKTFVQKLJtDNrrwZVjpERbAG0oAbr+kUOnE4dj+Bq78r9fhmfXa3HMMeBBqj8Rhamdv5qVdY9ALpKNcZNxDTKvzO6lxryGe7MCF58RZiLsyP6iB1wFlFqu1wzzYqO5rDbkg9/R/Kk8SAIJXwD0xKWopXHtIGMyNq (MillisBehindLatest=0)
2016/01/20 11:25:23 1 records read from shard shardId-000000000005 with iterator AAAAAAAAAAFn/W2pnwIeJ/93+8q5Ltep3GxXEq7hiM5WNW0XZDAtTL/VM+crpijK+R/h8zREDCyo73Nnim+tAdKwqLeP6uLJBVmOe9i/OQ/9tiupd+mu3CAWAeorDmLKAJfvg6ozljk/n8v2/6OI0v6glbZu98uxluHNZibyLVD2WCBM7U7QzrThJ9Qt1UwVwwjs99HCgktnXO+mWRpSgNnjhy6wG7Gf (MillisBehindLatest=0)
2016/01/20 11:25:23 2 records read from shard shardId-000000000000 with iterator AAAAAAAAAAFn/W2pnwIeJ/93+8q5Ltep3GxXEq7hiM5WNW0XZDAtTL/VM+crpijK+R/h8zREDCyVlDKE05/qz3F40TlmM+eIdWQ7OPDCLgj5c6dKhnKaT1cNN9WC3RnfO4VoLoVX+YGrvL9OPO631I6VJ3AFT11PmujX5CQl9KVbyMw0asGGOhA9ltCWAmZAVNuEFBNbd1eLnUNmRkLFUW/6lDuE5aJr (MillisBehindLatest=0)
2016/01/20 11:25:23 2 records read from shard shardId-000000000004 with iterator AAAAAAAAAAGZeJxXEj0SP1jSBLqWalUrTkFs6xi3RlyS9FcAJw+ve52LTvEMTvpazF86TIYia/yuljfAk+1gfH+aD7lfbkgoRHKt/9Z3JedAI++1TnIxAvIibMo3dNtl10crgU2Pffi8SECeceO1z0BYNbtEWMrMlOsmJqITc952Afh/Fr9E8DjyFO7TpzRo0ZzRr9WERE6ehc+sHhN4Bgu+BEOcPH2D (MillisBehindLatest=0)
2016/01/20 11:25:23 4 records read from shard shardId-000000000007 with iterator AAAAAAAAAAH5rzwEmfRnE9l3Kawhl9nYFLtSL/nOBTubf+8ZqmW7cXLs4y6FJ4Y8VLEuLujTrtddicPjpYzJbbh1bZ5xmH6cIUZyIQ4jVbdP8m1i+asA5gvmsk6l9p25sDSYFlzI83RxwTc5WuQdT5wPDvvcHFyHAVG+HoYRX+5X2QIPRWWKHKlT9FF5WKwXBMw1sryPR+JDkVrdO4MFE3sHT1jojfEo (MillisBehindLatest=0)
2016/01/20 11:25:23 3 records read from shard shardId-000000000001 with iterator AAAAAAAAAAGZeJxXEj0SP1jSBLqWalUrTkFs6xi3RlyS9FcAJw+ve52LTvEMTvpazF86TIYia/x2YMTs5CRhrTRzL1ly5qIyR+z1hMJQ4X6c6T3G1ANf5aSWjk/DPqnXhpVINmW9aqnotyEhVGp3BR0bhuJa81UVwixEiaUyEXWDO6TRwLg2Kzz789+XBQNKDlYKc2eJC13uyyZDfrHvYssiYhrJoLBF (MillisBehindLatest=0)
2016/01/20 11:25:23 0 records read from shard shardId-000000000005 with iterator AAAAAAAAAAELKq8DX0LHP1eCT44zbZo0zM4ohs2hF+gVMMpFah5wwDhU2381Y/TJgN4yUrZmQh3sTsO0ILdMuVgINalG7RRfERslYLwVK0Btgvl+LWDYcpMmgPMupst7orNhpXY+dv7H1l0ErU2vvLm6eWyEInUTTfvWq/gnkuZdE7/etlCG9Dmk17ggefbDUHklTc+I20BAI2lhhkC9p0LRDYS8HGzg (MillisBehindLatest=0)
2016/01/20 11:25:23 done with shard shardId-000000000005
2016/01/20 11:25:23 0 records read from shard shardId-000000000000 with iterator AAAAAAAAAAGpwoI+zW7PYpxNMX23C8lR0WOTLGwsq1lForPyb09+4x3XvNRQ1L9hSsPy3AaCccLeXQ+8rZ5e9YfZEwABcnRZyX6GRFLqml8Nhqt4yTrdzGGR+0XeDfF8rkusgyGaKIzwrBNlmjLNQ6ddvrnPNuXjwDQuuZ2nINwuBBmQxw21xpXQcFmXWiHXOPj6SjyLNAI1x1MT9KAY4dlczPfaqQvQ (MillisBehindLatest=0)
2016/01/20 11:25:23 done with shard shardId-000000000000
2016/01/20 11:25:23 5 records read from shard shardId-000000000003 with iterator AAAAAAAAAAFn/W2pnwIeJ/93+8q5Ltep3GxXEq7hiM5WNW0XZDAtTL/VM+crpijK+R/h8zREDCx3CQ8xkKcod0HY/JasJ/EqS22MG47OzIKyXQpg5+okiux1xUPW7NYEvpBODPLKWUS9MIUIOVffoGX6vwe9yvVHA+UCnlkSX5YEX3WBKwLJWRFeOcfpEs8l5DP6UMJ0K+LVUgbYAq9v2l+ShY9dDsar (MillisBehindLatest=0)
2016/01/20 11:25:23 0 records read from shard shardId-000000000004 with iterator AAAAAAAAAAGpwoI+zW7PYpxNMX23C8lR0WOTLGwsq1lForPyb09+4x3XvNRQ1L9hSsPy3AaCccIRPfqNpgqnLZ19qDfjRbgYK8GymNMAiG24Kn0maPrw3XIGGuhMNbJ1xBoqjG3V8OnkaAfvKlmL/75bgfuqB6wX7CxyAjz3qODKCBevP5GPWM46/5LthCHo8n3Auh+2XE3dctNIjRcEMzWoho3f6l0o (MillisBehindLatest=0)
2016/01/20 11:25:23 done with shard shardId-000000000004
2016/01/20 11:25:23 0 records read from shard shardId-000000000007 with iterator AAAAAAAAAAHtPv/Qc1e+JUA9yzoaCneS7oGDEBT31aKoUwADduqbIqDDGI+M2EVGzqr4hXbGlmIzwPMjBmn6Gcszpvzhz0wSFJeTLsumh27HojaMvcn41T7s2i8bhvNppQ1ktBfu49Tm0y+/tt0f13U0y2HHAUPyjQ6fKtf+7SrMEJZ21yy/TJSdCRA8VmVcX9rExVX71k5DcIt7QpPQmXQNqSsPyUIe (MillisBehindLatest=0)
2016/01/20 11:25:23 done with shard shardId-000000000007
2016/01/20 11:25:23 0 records read from shard shardId-000000000001 with iterator AAAAAAAAAAHtPv/Qc1e+JUA9yzoaCneS7oGDEBT31aKoUwADduqbIqDDGI+M2EVGzqr4hXbGlmKrUhVsPkgTh7qcTiS30r32Wbi84fCKqV343JJpzwWEZecpHgFTNv8IrYfhOZ6cLWxZlmHRmngFIhRyCye6V0cGe5PS1W8Z4mxxLNFqVyQInLZIKGvvI5rh4y5PbGnYrKsXsH/ThiDJot/eutZtg5SO (MillisBehindLatest=0)
2016/01/20 11:25:23 done with shard shardId-000000000001
2016/01/20 11:25:23 0 records read from shard shardId-000000000003 with iterator AAAAAAAAAAEg22ja29F+6r15vv64Xxg26Q5g7OqbLVB7V/GOHLG0PHvIB28AfEuoy1j+YZDGrUeROcKEAJ32aIwfDhmfZ0MA770R+VOc9B22aI9mdlTL90IehCxk2n9uysPGvIyUrOoK7jzgCp28rBmJQ3YB1nju1+Tgbf7U1XzNW+YV/jwJP4Tk5QmUq+ci6IG3qtYQ8NY2iDAhpX9xa+SM6cgMsguP (MillisBehindLatest=0)
2016/01/20 11:25:23 done with shard shardId-000000000003
2016/01/20 11:25:23 8 records read from shard shardId-000000000006 with iterator AAAAAAAAAAGZeJxXEj0SP1jSBLqWalUrTkFs6xi3RlyS9FcAJw+ve52LTvEMTvpazF86TIYia/z+6e4TuXPmMT8tHtTjTkTtxDx9+Iwc3ya8cML2WcsTeQ2j0wsrDu3H4VStT6ZuYGSGiojOd8WapnjFmksAgHAvw/q8gJBHL+mQOcyO0RF+Y46OvmfAKGdCTUxjAJCqJszU0/Wy88tN2FLI9ABLmG3l (MillisBehindLatest=0)
2016/01/20 11:25:23 0 records read from shard shardId-000000000006 with iterator AAAAAAAAAAFDmvx8h9iNi3QtPOHrTQE7KG6yin9WLD5mt3o3IBAz9aSgw5EtdHmyeH5e8HrbEd8XM6NAkBOHQnty99dqUdvtjyS2e1oZthYeyS/qFXfNPanMBZvBQ20n4spR8bNrdwphHWjf6Is6nVTtRl9GGg70CUujbknNRQNdPlA6kl6I5RqTVvXiXUcEQJqIpsKIxBrVlKLCrbQrp2psYvuZoAk8 (MillisBehindLatest=0)
2016/01/20 11:25:23 done with shard shardId-000000000006
2016/01/20 11:25:23 records fetched
2016/01/20 11:25:23 100 messages
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment