Skip to content

Commit d5019b0

Browse files
committed
fix test
1 parent 027dc5f commit d5019b0

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

writer_test.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -166,15 +166,15 @@ func testWriterMaxAttemptsErr(t *testing.T) {
166166
const topic = "test-writer-2"
167167
const maxAttempts = 3
168168

169-
var fw fakeWriter
169+
fw := &fakeWriter{}
170170

171171
createTopic(t, topic, 1)
172172
w := newTestWriter(WriterConfig{
173173
Topic: topic,
174-
MaxAttempts: 1,
174+
MaxAttempts: maxAttempts,
175175
Balancer: &RoundRobin{},
176176
newPartitionWriter: func(p int, config WriterConfig, stats *writerStats) partitionWriter {
177-
return &fw
177+
return fw
178178
},
179179
})
180180
defer w.Close()

0 commit comments

Comments
 (0)