Skip to content

Commit edfce2f

Browse files
nodeceRobertIndie
andauthored
Update pulsar/producer_test.go
Co-authored-by: Zike Yang <[email protected]>
1 parent 687c80a commit edfce2f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pulsar/producer_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2644,7 +2644,7 @@ func testProducerKeepReconnectingAndThenCallSendAsync(t *testing.T, isEnabledBat
26442644
Topic: newTopicName(),
26452645
Schema: NewBytesSchema(nil),
26462646
SendTimeout: 3 * time.Second,
2647-
DisableBatching: isEnabledBatching,
2647+
DisableBatching: isDisableBatching,
26482648
})
26492649
return err == nil
26502650
}, 30*time.Second, 1*time.Second)

0 commit comments

Comments
 (0)