panic: runtime error: invalid memory address or nil pointer dereference
[signal 0xb code=0x1 addr=0x48 pc=0x453c79]
goroutine 35 [running]:
github.com/stealthly/go_kafka_client.(_SiestaClient).GetOffset(0xc20805e160, 0xc2080d605e, 0x11, 0xc2080b3139, 0x5, 0xc200000000, 0x77be00, 0x0, 0x0)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/low_level_client.go:330 +0x89
github.com/stealthly/go_kafka_client.(_Consumer).fetchOffsets(0xc20807a0b0, 0xc208038100, 0x1, 0x1, 0x1, 0x0, 0x0)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:785 +0x133
github.com/stealthly/go_kafka_client.tryRebalance(0xc20807a0b0, 0xc2084321b0, 0x9e58e0, 0xc2080d605e)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:708 +0x27b
github.com/stealthly/go_kafka_client.func·011()
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:676 +0xe58
github.com/stealthly/go_kafka_client.inLock(0xc20807a0d8, 0xc20842ff08)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/utils.go:44 +0x51
github.com/stealthly/go_kafka_client.(_Consumer).rebalance(0xc20807a0b0)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:695 +0x73
github.com/stealthly/go_kafka_client.(_Consumer).reinitializeConsumer(0xc20807a0b0)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:305 +0x4e
github.com/stealthly/go_kafka_client.(_Consumer).createMessageStreams(0xc20807a0b0, 0xc20809c780)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:280 +0x190
created by github.com/stealthly/go_kafka_client.(_Consumer).StartStatic
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:110 +0x3c
goroutine 1 [select]:
github.com/stealthly/go_kafka_client.(_Consumer).startStreams(0xc20807a0b0)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:188 +0x9f9
github.com/stealthly/go_kafka_client.(_Consumer).StartStatic(0xc20807a0b0, 0xc20809c780)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:112 +0x4c
main.(*DemoConsumer).Start(0xc20801ea00)
/home/eyu/workspace/src/ac-kafka/demo/simple_consumer/simple_consumer.go:25 +0xa7
main.main()
/home/eyu/workspace/src/ac-kafka/demo/simple_consumer/simple_consumer.go:66 +0x12b
goroutine 5 [chan receive]:
ac-common-go/glog.(*loggingT).flushDaemon(0xb532e0)
/home/eyu/workspace/src/ac-common-go/glog/glog.go:868 +0x78
created by ac-common-go/glog.init·1
/home/eyu/workspace/src/ac-common-go/glog/glog.go:411 +0x31d
goroutine 17 [syscall, locked to thread]:
runtime.goexit()
/home/eyu/go/src/runtime/asm_amd64.s:2232 +0x1
goroutine 7 [semacquire]:
sync.(_Cond).Wait(0xc20802afc0)
/home/eyu/go/src/sync/cond.go:62 +0x9e
github.com/cihub/seelog.(_asyncLoopLogger).processItem(0xc208082000, 0x420200)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:50 +0xe0
github.com/cihub/seelog.(*asyncLoopLogger).processQueue(0xc208082000)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:63 +0x47
created by github.com/cihub/seelog.newAsyncLoopLogger
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:40 +0x8e
goroutine 8 [semacquire]:
sync.(_Cond).Wait(0xc20802b140)
/home/eyu/go/src/sync/cond.go:62 +0x9e
github.com/cihub/seelog.(_asyncLoopLogger).processItem(0xc208082100, 0x0)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:50 +0xe0
github.com/cihub/seelog.(*asyncLoopLogger).processQueue(0xc208082100)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:63 +0x47
created by github.com/cihub/seelog.newAsyncLoopLogger
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:40 +0x8e
goroutine 9 [semacquire]:
sync.(_Cond).Wait(0xc20802b6c0)
/home/eyu/go/src/sync/cond.go:62 +0x9e
github.com/cihub/seelog.(_asyncLoopLogger).processItem(0xc208082280, 0x0)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:50 +0xe0
github.com/cihub/seelog.(*asyncLoopLogger).processQueue(0xc208082280)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:63 +0x47
created by github.com/cihub/seelog.newAsyncLoopLogger
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:40 +0x8e
goroutine 10 [runnable]:
github.com/stealthly/go_kafka_client.(_TopicAndPartition).String(0xc2083ff960, 0x8248e0, 0xc2083ff960)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/structs.go:128
fmt.(_pp).handleMethods(0xc208090000, 0xc200000073, 0x0, 0x1)
/home/eyu/go/src/fmt/print.go:720 +0x579
fmt.(_pp).printArg(0xc208090000, 0x8248e0, 0xc2083ff960, 0x73, 0x0, 0x0)
/home/eyu/go/src/fmt/print.go:794 +0x3b8
fmt.(_pp).doPrintf(0xc208090000, 0xc2083ff9c0, 0x1d, 0xc2083ff980, 0x2, 0x2)
/home/eyu/go/src/fmt/print.go:1183 +0x21cd
fmt.Sprintf(0xc2083ff9c0, 0x1d, 0xc2083ff980, 0x2, 0x2, 0x0, 0x0)
/home/eyu/go/src/fmt/print.go:203 +0x78
github.com/cihub/seelog.(_logFormattedMessage).String(0xc2080b5d70, 0x0, 0x0)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/logger.go:361 +0x62
github.com/cihub/seelog.(_commonLogger).processLogMsg(0xc208082400, 0x86b802, 0x7f04efa14a60, 0xc2080b5d70, 0x7f04efa14a88, 0xc20843e180)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/logger.go:304 +0x8a
github.com/cihub/seelog.(_asyncLogger).processQueueElement(0xc208082400)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclogger.go:115 +0xd3
github.com/cihub/seelog.(_asyncLoopLogger).processItem(0xc208082400, 0x0)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:57 +0x132
github.com/cihub/seelog.(*asyncLoopLogger).processQueue(0xc208082400)
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:63 +0x47
created by github.com/cihub/seelog.newAsyncLoopLogger
/home/eyu/workspace/src/ac-kafka/src/github.com/cihub/seelog/behavior_asynclooplogger.go:40 +0x8e
goroutine 18 [semacquire]:
sync.(_WaitGroup).Wait(0xc20805e1e0)
/home/eyu/go/src/sync/waitgroup.go:132 +0x169
github.com/samuel/go-zookeeper/zk.(_Conn).loop(0xc2080b80e0)
/home/eyu/workspace/src/ac-kafka/src/github.com/samuel/go-zookeeper/zk/conn.go:287 +0x78c
github.com/samuel/go-zookeeper/zk.func·001()
/home/eyu/workspace/src/ac-kafka/src/github.com/samuel/go-zookeeper/zk/conn.go:185 +0x2c
created by github.com/samuel/go-zookeeper/zk.ConnectWithDialer
/home/eyu/workspace/src/ac-kafka/src/github.com/samuel/go-zookeeper/zk/conn.go:189 +0x606
goroutine 19 [chan receive]:
github.com/stealthly/go_kafka_client.(_ZookeeperCoordinator).listenConnectionEvents(0xc20803ade0, 0xc2080e0060)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/zk_coordinator.go:90 +0x68
created by github.com/stealthly/go_kafka_client.(_ZookeeperCoordinator).Connect
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/zk_coordinator.go:67 +0xe1
goroutine 15 [select]:
github.com/Shopify/sarama.(_client).backgroundMetadataUpdater(0xc2080b6000)
/home/eyu/workspace/src/ac-kafka/src/github.com/Shopify/sarama/client.go:553 +0x2f3
github.com/Shopify/sarama._client.(github.com/Shopify/sarama.backgroundMetadataUpdater)·fm()
/home/eyu/workspace/src/ac-kafka/src/github.com/Shopify/sarama/client.go:142 +0x27
github.com/Shopify/sarama.withRecover(0xc20800af10)
/home/eyu/workspace/src/ac-kafka/src/github.com/Shopify/sarama/utils.go:42 +0x3a
created by github.com/Shopify/sarama.NewClient
/home/eyu/workspace/src/ac-kafka/src/github.com/Shopify/sarama/client.go:142 +0x8ce
goroutine 11 [select]:
github.com/samuel/go-zookeeper/zk.(_Conn).sendLoop(0xc2080b80e0, 0x7f04efa14ea8, 0xc2080ec010, 0xc2080347e0, 0x0, 0x0)
/home/eyu/workspace/src/ac-kafka/src/github.com/samuel/go-zookeeper/zk/conn.go:483 +0xce9
github.com/samuel/go-zookeeper/zk.func·002()
/home/eyu/workspace/src/ac-kafka/src/github.com/samuel/go-zookeeper/zk/conn.go:272 +0x5a
created by github.com/samuel/go-zookeeper/zk.(_Conn).loop
/home/eyu/workspace/src/ac-kafka/src/github.com/samuel/go-zookeeper/zk/conn.go:275 +0x69f
goroutine 12 [IO wait]:
net.(_pollDesc).Wait(0xc2080100d0, 0x72, 0x0, 0x0)
/home/eyu/go/src/net/fd_poll_runtime.go:84 +0x47
net.(_pollDesc).WaitRead(0xc2080100d0, 0x0, 0x0)
/home/eyu/go/src/net/fd_poll_runtime.go:89 +0x43
net.(_netFD).Read(0xc208010070, 0xc208276000, 0x4, 0x180000, 0x0, 0x7f04efa10fb8, 0xc20843a670)
/home/eyu/go/src/net/fd_unix.go:242 +0x40f
net.(_conn).Read(0xc2080ec010, 0xc208276000, 0x4, 0x180000, 0x0, 0x0, 0x0)
/home/eyu/go/src/net/net.go:121 +0xdc
io.ReadAtLeast(0x7f04efa15f68, 0xc2080ec010, 0xc208276000, 0x4, 0x180000, 0x4, 0x0, 0x0, 0x0)
/home/eyu/go/src/io/io.go:298 +0xf1
io.ReadFull(0x7f04efa15f68, 0xc2080ec010, 0xc208276000, 0x4, 0x180000, 0x0, 0x0, 0x0)
/home/eyu/go/src/io/io.go:316 +0x6d
github.com/samuel/go-zookeeper/zk.(_Conn).recvLoop(0xc2080b80e0, 0x7f04efa14ea8, 0xc2080ec010, 0x0, 0x0)
/home/eyu/workspace/src/ac-kafka/src/github.com/samuel/go-zookeeper/zk/conn.go:547 +0x1b6
github.com/samuel/go-zookeeper/zk.func·003()
/home/eyu/workspace/src/ac-kafka/src/github.com/samuel/go-zookeeper/zk/conn.go:279 +0x5f
created by github.com/samuel/go-zookeeper/zk.(_Conn).loop
/home/eyu/workspace/src/ac-kafka/src/github.com/samuel/go-zookeeper/zk/conn.go:285 +0x77c
goroutine 14 [chan receive]:
github.com/Shopify/sarama.(_Broker).responseReceiver(0xc2080da070)
/home/eyu/workspace/src/ac-kafka/src/github.com/Shopify/sarama/broker.go:345 +0xe3
github.com/Shopify/sarama._Broker.(github.com/Shopify/sarama.responseReceiver)·fm()
/home/eyu/workspace/src/ac-kafka/src/github.com/Shopify/sarama/broker.go:98 +0x27
github.com/Shopify/sarama.withRecover(0xc20800ac20)
/home/eyu/workspace/src/ac-kafka/src/github.com/Shopify/sarama/utils.go:42 +0x3a
created by github.com/Shopify/sarama.func·006
/home/eyu/workspace/src/ac-kafka/src/github.com/Shopify/sarama/broker.go:98 +0x666
goroutine 16 [chan receive]:
github.com/rcrowley/go-metrics.(*meterArbiter).tick(0xb52f40)
/home/eyu/workspace/src/ac-kafka/src/github.com/rcrowley/go-metrics/meter.go:221 +0x52
created by github.com/rcrowley/go-metrics.NewMeter
/home/eyu/workspace/src/ac-kafka/src/github.com/rcrowley/go-metrics/meter.go:40 +0x1f7
goroutine 34 [chan receive]:
github.com/stealthly/go_kafka_client.func·001()
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:95 +0x48
created by github.com/stealthly/go_kafka_client.NewConsumer
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:99 +0x76f
goroutine 36 [select]:
github.com/stealthly/go_kafka_client.func·003()
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:231 +0x2c9
created by github.com/stealthly/go_kafka_client.(*Consumer).maintainCleanCoordinator
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:239 +0xdf
goroutine 22 [select]:
reflect.Select(0xc2080ae1c0, 0x5, 0x8, 0x0, 0x0, 0x0, 0x0, 0x0)
/home/eyu/go/src/reflect/value.go:1965 +0x218
github.com/stealthly/go_kafka_client.func·035()
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/utils.go:197 +0x7a
created by github.com/stealthly/go_kafka_client.redirectChannelsToWithTimeout
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/utils.go:216 +0xbdb
goroutine 23 [select]:
github.com/stealthly/go_kafka_client.func·050()
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/zk_coordinator.go:511 +0x1634
created by github.com/stealthly/go_kafka_client.(*ZookeeperCoordinator).trySubscribeForChanges
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/zk_coordinator.go:562 +0xbdb
goroutine 24 [select]:
github.com/stealthly/go_kafka_client.func·010()
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:584 +0x510
created by github.com/stealthly/go_kafka_client.(*Consumer).subscribeForChanges
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/consumer.go:621 +0x1dc
goroutine 25 [chan receive]:
github.com/stealthly/go_kafka_client.func·051(0xc20808d6e0)
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/zk_coordinator.go:757 +0x3d
created by github.com/stealthly/go_kafka_client.(*ZookeeperCoordinator).waitForMembersToJoin
/home/eyu/workspace/src/ac-kafka/src/github.com/stealthly/go_kafka_client/zk_coordinator.go:773 +0x45e