We'll need a timeout here because unless I'm missing something, this method could block forever (or at least make the test run longer than necessary) if the expected number records aren't received.
Another plug for using `IntegrationTestUtils.wait..` methods as those methods provide timeout functionality. [ Full content available at: https://github.com/apache/kafka/pull/5567 ] This message was relayed via gitbox.apache.org for [email protected]
