Revert "Pin to sarama cluster without message drain race condition on…

.travis.yml

@@ -1,6 +1,7 @@
 language: go
 sudo: false
 go:
+  - 1.8
   - 1.9
 go_import_path: github.com/uber-go/kafka-client
 cache:
@@ -14,4 +15,4 @@ script:
   - make bench
 after_success:
   - make cover
-  - bash <(curl -s https://codecov.io/bash)
+  - bash <(curl -s https://codecov.io/bash)

glide.yaml

@@ -8,7 +8,7 @@ import:
 - package: github.com/Shopify/sarama
   version: ^1
 - package: github.com/bsm/sarama-cluster
-  version: abb0e9f5dd57b5a3167e1472136a84c4b989478b
+  version: ~2.1.13
 - package: github.com/golang/protobuf
   version: ^1
 testImport:

internal/consumer/mocks_test.go

@@ -284,18 +284,6 @@ func (m *mockPartitionedConsumer) Partition() int32 {
 	return m.id
 }
 
-func (m *mockPartitionedConsumer) InitialOffset() int64 {
-	panic("implement me")
-}
-
-func (m *mockPartitionedConsumer) MarkOffset(offset int64, metadata string) {
-	panic("implement me")
-}
-
-func (m *mockPartitionedConsumer) ResetOffset(offset int64, metadata string) {
-	panic("implement me")
-}
-
 func newMockSaramaConsumer() *mockSaramaConsumer {
 	return &mockSaramaConsumer{
 		errorC:     make(chan error, 1),
@@ -408,10 +396,6 @@ func newMockSaramaClient() *mockSaramaClient {
 	}
 }
 
-func (m *mockSaramaClient) Controller() (*sarama.Broker, error) {
-	panic("implement me")
-}
-
 func (m *mockSaramaClient) Config() *sarama.Config {
 	panic("implement me")
 }