Skip to content

Commit

Permalink
Reduce fetching intervals in test
Browse files Browse the repository at this point in the history
  • Loading branch information
atanasdinov committed Mar 28, 2022
1 parent 451ec86 commit b7cebb5
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions consumer_monitor_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -306,8 +306,8 @@ func (w *mockBrokerWrapper) setOffsetFetchResponses(consumerOffsetResponse *sara
}

func TestConsumerMonitor_Workflow(t *testing.T) {
fetchInterval := 1650 * time.Millisecond
fetchHandlingInterval := 1800 * time.Millisecond
fetchInterval := 550 * time.Millisecond
fetchHandlingInterval := 600 * time.Millisecond

config := ConsumerConfig{
ConsumerGroup: testConsumerGroup,
Expand Down

0 comments on commit b7cebb5

Please sign in to comment.