(de)serialization of initial offsets | 0.29 sec | Passed |
Kafka column types | 1.2 sec | Passed |
KafkaSource with watermark | 2.2 sec | Passed |
SPARK-22956: currentPartitionOffsets should be set when no new data comes in | 3.4 sec | Passed |
SPARK-25495: FetchedData.reset should reset all fields | 2.1 sec | Passed |
SPARK-26718 Rate limit set to Long.Max should not overflow integer during end offset calculation | 1.1 sec | Passed |
SPARK-27494: read kafka record containing null key/values. | 1.2 sec | Passed |
V2 Source is used by default | 0.28 sec | Passed |
assign from earliest offsets (failOnDataLoss: false) | 5.4 sec | Passed |
assign from earliest offsets (failOnDataLoss: true) | 5.6 sec | Passed |
assign from latest offsets (failOnDataLoss: false) | 5.6 sec | Passed |
assign from latest offsets (failOnDataLoss: true) | 7 sec | Passed |
assign from specific offsets (failOnDataLoss: false) | 3.4 sec | Passed |
assign from specific offsets (failOnDataLoss: true) | 3.5 sec | Passed |
bad source options | 24 ms | Passed |
cannot stop Kafka stream | 5.6 sec | Passed |
delete a topic when a Spark job is running | 3.8 sec | Passed |
deserialization of initial offset written by Spark 2.1.0 (SPARK-19517) | 2.1 sec | Passed |
deserialization of initial offset written by future version | 0.14 sec | Passed |
ensure stream-stream self-join generates only one offset in log and correct metrics | 6.6 sec | Passed |
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517) | 0.33 sec | Passed |
get offsets from case insensitive parameters | 3 ms | Passed |
input row metrics | 1.7 sec | Passed |
maxOffsetsPerTrigger | 3.3 sec | Passed |
minPartitions is supported | 0.27 sec | Passed |
read Kafka transactional messages: read_committed | 14 sec | Passed |
read Kafka transactional messages: read_uncommitted | 9.4 sec | Passed |
subscribe topic by pattern with topic recreation between batches | 3.2 sec | Passed |
subscribing topic by name from earliest offsets (failOnDataLoss: false) | 6.5 sec | Passed |
subscribing topic by name from earliest offsets (failOnDataLoss: true) | 6.1 sec | Passed |
subscribing topic by name from latest offsets (failOnDataLoss: false) | 6.1 sec | Passed |
subscribing topic by name from latest offsets (failOnDataLoss: true) | 7.4 sec | Passed |
subscribing topic by name from specific offsets (failOnDataLoss: false) | 3.4 sec | Passed |
subscribing topic by name from specific offsets (failOnDataLoss: true) | 3.5 sec | Passed |
subscribing topic by pattern from earliest offsets (failOnDataLoss: false) | 6.6 sec | Passed |
subscribing topic by pattern from earliest offsets (failOnDataLoss: true) | 6.6 sec | Passed |
subscribing topic by pattern from latest offsets (failOnDataLoss: false) | 7.4 sec | Passed |
subscribing topic by pattern from latest offsets (failOnDataLoss: true) | 7.4 sec | Passed |
subscribing topic by pattern from specific offsets (failOnDataLoss: false) | 3.7 sec | Passed |
subscribing topic by pattern from specific offsets (failOnDataLoss: true) | 3.5 sec | Passed |
subscribing topic by pattern with topic deletions | 4.3 sec | Passed |
unsupported kafka configs | 23 ms | Passed |