Consumer Group Example

[trotha01]

An example of how to create a consumer with a specific consumer group would be nice.

I didn't see it in the *Config that is passed into NewConsumer(), so I'm not sure how I would create a consumer for a specific consumer group.

[eapache]

At the moment sarama doesn't include the zookeeper logic necessary to register and consume as part of a consumer group. That logic is currently in a separate package (https://github.com/wvanbergen/kafka) though we do hope to integrate it eventually.

[trotha01]

I'll check out that package. Thank you for the very quick response!

[wvanbergen]

An example of said library can be found here: https://github.com/wvanbergen/kafka/blob/master/examples/consumergroup/main.go

It's definitely more experimental than sarama, feedback is welcome!

At the same time, we're also brainstorming on how to make it easier to consume all partitions of a topic in #366, and implement offset management in #379

[dzlab]

Has this package been integrated to sarama or not yet??

[eapache]

No, we are still waiting on upstream Kafka to release a version of the final API for consumers that does not depend on zookeeper.

[felipejfc]

bump

[eapache]

See #597