Skip to content
This repository was archived by the owner on Oct 7, 2022. It is now read-only.

Commit e3991e5

Browse files
committed
fix(consumer_test): increase time range assertion
1 parent 95dedd4 commit e3991e5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/kafka/consumer_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ func TestKafka_Start(t *testing.T) {
122122
err = json.Unmarshal(*res.Source, &r)
123123
if assert.NoError(t, err) {
124124
assert.Equal(t, rec.Id, r.Id)
125-
assert.InDelta(t, expectedTimestamp, r.Timestamp, 1000.0)
125+
assert.InDelta(t, expectedTimestamp, r.Timestamp, 5000.0)
126126
}
127127
}
128128
signals <- os.Interrupt

0 commit comments

Comments
 (0)