We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6586446 commit 3fe47c7Copy full SHA for 3fe47c7
core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala
@@ -167,7 +167,6 @@ abstract class BaseQuotaTest extends IntegrationTestHarness {
167
// consume from beginning till throttled
168
quotaTestClients.consumer.seekToBeginning(Collections.singleton(new TopicPartition(topic1, 0)))
169
quotaTestClients.consumeUntilThrottled(numRecords + produced)
170
- System.out.print(numRecords + produced)
171
quotaTestClients.verifyConsumeThrottle(expectThrottle = true)
172
}
173
0 commit comments