Test Result : DirectKafkaStreamSuite

0 failures (±0)
14 tests (±0)
Took 23 sec.

All Tests

Test nameDurationStatus
Direct Kafka stream report input information1.8 secPassed
basic stream receiving with multiple topics and smallest starting offset3.9 secPassed
creating stream by offset0.63 secPassed
initialRate should honor maxRatePerPartition0.98 secPassed
initialRate with backpressure0.96 secPassed
maxMessagesPerPartition respects max rate93 msPassed
maxMessagesPerPartition with backpressure disabled0.15 secPassed
maxMessagesPerPartition with no lag0.15 secPassed
maxMessagesPerPartition with zero offset and rate equal to the specified minimum with default 10.11 secPassed
offset recovery5.9 secPassed
offset recovery from kafka1.3 secPassed
pattern based subscription3.4 secPassed
receiving from largest starting offset0.6 secPassed
using rate controller2.6 secPassed