Skip to content

Commit

Permalink
Merge pull request #438 from Shopify/doc-consumer-group
Browse files Browse the repository at this point in the history
Document consumergroup repo location
  • Loading branch information
eapache committed Apr 30, 2015
2 parents a309484 + 7c4fa74 commit 2fdd6bd
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,10 @@ func (ce ConsumerErrors) Error() string {
// Consumer manages PartitionConsumers which process Kafka messages from brokers. You MUST call Close()
// on a consumer to avoid leaks, it will not be garbage-collected automatically when it passes out of
// scope.
//
// Sarama's Consumer type does not currently support automatic consumer group rebalancing and offset tracking,
// however the https://github.com/wvanbergen/kafka library builds on Sarama to add this support. We plan
// to properly integrate this functionality at a later date.
type Consumer interface {

// Topics returns the set of available topics as retrieved from the cluster metadata.
Expand Down

0 comments on commit 2fdd6bd

Please sign in to comment.