Kafka column types | 1.9 sec | Passed |
SPARK-27494: read kafka record containing null key/values | 5 sec | Passed |
assign from earliest offsets (failOnDataLoss: false) | 10 sec | Passed |
assign from earliest offsets (failOnDataLoss: true) | 32 sec | Passed |
assign from latest offsets (failOnDataLoss: false) | 11 sec | Passed |
assign from latest offsets (failOnDataLoss: true) | 15 sec | Passed |
assign from specific offsets (failOnDataLoss: false) | 4 sec | Passed |
assign from specific offsets (failOnDataLoss: true) | 4.7 sec | Passed |
assign from specific timestamps (failOnDataLoss: false) | 8.2 sec | Passed |
assign from specific timestamps (failOnDataLoss: true) | 8.9 sec | Passed |
bad source options | 15 ms | Passed |
cannot stop Kafka stream | 3.7 sec | Passed |
ensure continuous stream is being used | 0.13 sec | Passed |
get offsets from case insensitive parameters | 0 ms | Passed |
read Kafka transactional messages: read_committed | 7.9 sec | Passed |
read Kafka transactional messages: read_uncommitted | 6.8 sec | Passed |
subscribing topic by name from earliest offsets (failOnDataLoss: false) | 9 sec | Passed |
subscribing topic by name from earliest offsets (failOnDataLoss: true) | 14 sec | Passed |
subscribing topic by name from latest offsets (failOnDataLoss: false) | 38 sec | Passed |
subscribing topic by name from latest offsets (failOnDataLoss: true) | 12 sec | Passed |
subscribing topic by name from specific offsets (failOnDataLoss: false) | 4 sec | Passed |
subscribing topic by name from specific offsets (failOnDataLoss: true) | 8.9 sec | Passed |
subscribing topic by name from specific timestamps (failOnDataLoss: false) | 10 sec | Passed |
subscribing topic by name from specific timestamps (failOnDataLoss: true) | 7.9 sec | Passed |
subscribing topic by pattern from earliest offsets (failOnDataLoss: false) | 9.8 sec | Passed |
subscribing topic by pattern from earliest offsets (failOnDataLoss: true) | 15 sec | Passed |
subscribing topic by pattern from latest offsets (failOnDataLoss: false) | 17 sec | Passed |
subscribing topic by pattern from latest offsets (failOnDataLoss: true) | 13 sec | Passed |
subscribing topic by pattern from specific offsets (failOnDataLoss: false) | 5.9 sec | Passed |
subscribing topic by pattern from specific offsets (failOnDataLoss: true) | 3.8 sec | Passed |
subscribing topic by pattern from specific timestamps (failOnDataLoss: false) | 16 sec | Passed |
subscribing topic by pattern from specific timestamps (failOnDataLoss: true) | 10 sec | Passed |
unsupported kafka configs | 65 ms | Passed |