Skip to content

Commit

Permalink
Merge branch '5.2.1-post' into 5.2.2-post
Browse files Browse the repository at this point in the history
  • Loading branch information
bbejeck committed Aug 20, 2019
2 parents 2f7b92c + 74e10cd commit f0fb4e9
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -116,7 +116,7 @@ private static <K, V> List<KeyValue<K, V>> readKeysAndValues(final int numberToR
actualValues.add(KeyValue.pair(record.key(), record.value()));
}
return actualValues.size() == numberToRead;
}, 30000, "Timed out reading orders.");
}, 40000, "Timed out reading orders.");
consumer.close();
return actualValues;
}
Expand Down

0 comments on commit f0fb4e9

Please sign in to comment.