panic: invalid memory address or nil pointer dereference

[jaredye]

panic: runtime error: invalid memory address or nil pointer dereference
[signal 0xb code=0x1 addr=0x48 pc=0x5472e0]

goroutine 167 [running]:
github.com/wvanbergen/kafka/consumergroup.(*ConsumerGroup).partitionConsumer(0xc8201745a0, 0xc82013b180, 0x11, 0x0, 0xc8204e0420, 0xc8204e0480, 0xc8206a4b50, 0xc8206709c0)
        /go/src/xxxx/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup/consumer_group.go:435 +0x1580
created by github.com/wvanbergen/kafka/consumergroup.(*ConsumerGroup).topicConsumer
        /go/src/xxxx/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup/consumer_group.go:341 +0xbd6

        {
            "ImportPath": "github.com/wvanbergen/kafka/consumergroup",
            "Rev": "1ff806bb203e104e04d49189220d267d37e46758"
        },
        {
            "ImportPath": "github.com/Shopify/sarama",
            "Comment": "v1.8.0-49-g89bd629",
            "Rev": "89bd629b50e1a69c40d40ded1c82a767b4859442"
        },

kafka 0.9.0.0

The process panic every 10 minutes.

[warebot]

Running into the same issue.

• Kafka 0.8.11
• sarama: commit "c372abcbb917eb838df44dd6a0cfc3a43dba6fd2" Merge: "e4bd495 484777e"
• kafka/consumergroup: commit "1ff806bb203e104e04d49189220d267d37e46758" Merge: "46f9a1c 610c397"

Looks like the issue is due to nil messages being consumed off the channel (via sarama consumer). Clearly, trying to access the Offset field on a nil object will cause a panic.

[warebot]

Hi @jaredye I applied a patch on my personal fork. Would you mind doing a quick test run? Curious to see if it solves your problem as well. https://github.com/warebot/kafka