Test Result : DirectKafkaStreamSuite

0 failures

14 tests

All Tests

Test name	Duration	Status
Direct Kafka stream report input information	0.49 sec	Passed
basic stream receiving with multiple topics and smallest starting offset	2.9 sec	Passed
creating stream by offset	0.27 sec	Passed
initialRate should honor maxRatePerPartition	0.34 sec	Passed
initialRate with backpressure	0.33 sec	Passed
maxMessagesPerPartition respects max rate	70 ms	Passed
maxMessagesPerPartition with backpressure disabled	77 ms	Passed
maxMessagesPerPartition with no lag	0.1 sec	Passed
maxMessagesPerPartition with zero offset and rate equal to the specified minimum with default 1	63 ms	Passed
offset recovery	2.5 sec	Passed
offset recovery from kafka	0.6 sec	Passed
pattern based subscription	2.7 sec	Passed
receiving from largest starting offset	0.41 sec	Passed
using rate controller	2.7 sec	Passed