Test Result : DirectKafkaStreamSuite

0 failures
14 tests
Took 14 sec.

All Tests

Test nameDurationStatus
Direct Kafka stream report input information0.49 secPassed
backpressure.initialRate should honor maxRatePerPartition0.28 secPassed
basic stream receiving with multiple topics and smallest starting offset2.9 secPassed
creating stream by offset0.35 secPassed
maxMessagesPerPartition respects max rate95 msPassed
maxMessagesPerPartition with backpressure disabled0.11 secPassed
maxMessagesPerPartition with no lag98 msPassed
maxMessagesPerPartition with zero offset and rate equal to the specified minimum with default 191 msPassed
offset recovery3.4 secPassed
offset recovery from kafka0.56 secPassed
pattern based subscription2.6 secPassed
receiving from largest starting offset0.34 secPassed
use backpressure.initialRate with backpressure0.3 secPassed
using rate controller2.2 secPassed