We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e7d5971 commit 92a22baCopy full SHA for 92a22ba
writer_test.go
@@ -52,7 +52,7 @@ func TestWriter(t *testing.T) {
52
function: testWriterSetsRightBalancer,
53
},
54
{
55
- scenario: "setting RequiredAcks to None in Writer doesn't cause a panic",
+ scenario: "setting RequiredAcks to None in Writer does not cause a panic",
56
function: testWriterRequiredAcksNone,
57
58
}
@@ -93,9 +93,9 @@ func testWriterRequiredAcksNone(t *testing.T) {
93
defer deleteTopic(t, topic)
94
95
w := &Writer{
96
- Addr: TCP("localhost:9092"),
97
- Topic: topic,
98
- Balancer: &RoundRobin{},
+ Addr: TCP("localhost:9092"),
+ Topic: topic,
+ Balancer: &RoundRobin{},
99
RequiredAcks: RequireNone,
100
101
defer w.Close()
0 commit comments