fix bug. make sure all data has consumed in successChan

elodina / go_kafka_client

Apache Kafka Client Library for Go

http://www.elodina.net

Apache License 2.0

275 stars 74 forks source link

fix bug. make sure all data has consumed in successChan #171

Closed xiocode closed 8 years ago

xiocode commented 8 years ago

successChan's data haven't consumed before check successfullyOwnedPartitions's length. it will cause panic Consumer failed to reflect all partitions ...

serejja commented 8 years ago

Cool, thanks!