reader/kafka: improve status check
@@ -30,8 +30,8 @@ func TestKafkaReader(t *testing.T) {
ZookeeperPeers: []string{"localhost:2181"},
ZookeeperTimeout: time.Second,
Whence: "oldest",
- errs: make(chan error, 1000),
- mux: new(sync.Mutex),
+ errChan: make(chan error, 1000),
+ lock: new(sync.Mutex),
statsLock: new(sync.RWMutex),
}
assert.EqualValues(t, "KafkaReader:[topic1],[group1]", er.Name())
