|
@@ -4,7 +4,6 @@ import (
|
|
|
"io"
|
|
"io"
|
|
|
"sync"
|
|
"sync"
|
|
|
"testing"
|
|
"testing"
|
|
|
- "time"
|
|
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
func safeClose(t *testing.T, c io.Closer) {
|
|
func safeClose(t *testing.T, c io.Closer) {
|
|
@@ -79,7 +78,6 @@ func TestClientDoesntCachePartitionsForTopicsWithErrors(t *testing.T) {
|
|
|
seedBroker.Returns(metadataResponse)
|
|
seedBroker.Returns(metadataResponse)
|
|
|
|
|
|
|
|
config := NewConfig()
|
|
config := NewConfig()
|
|
|
- config.Net.KeepAlive = 12 * time.Millisecond
|
|
|
|
|
config.Metadata.Retry.Max = 0
|
|
config.Metadata.Retry.Max = 0
|
|
|
client, err := NewClient([]string{seedBroker.Addr()}, config)
|
|
client, err := NewClient([]string{seedBroker.Addr()}, config)
|
|
|
if err != nil {
|
|
if err != nil {
|
eric