line |
l |
!l&&r |
!l&&!r |
condition |
700
|
0 |
0 |
0 |
$api_version //= $DEFAULT_APIVERSION |
883
|
0 |
0 |
98 |
$api_version //= $DEFAULT_APIVERSION |
1024
|
0 |
0 |
5021 |
$api_version //= $DEFAULT_APIVERSION |
1050
|
0 |
0 |
5021 |
$is_v1 or $is_v2 |
|
0 |
0 |
5021 |
$is_v1 or $is_v2 or $is_v3 |
1222
|
18 |
0 |
5 |
$api_version //= $DEFAULT_APIVERSION |
1743
|
18 |
0 |
10262 |
$request_ref->{'ApiVersion'} // $DEFAULT_APIVERSION |
1765
|
0 |
0 |
5021 |
$is_v1 or $is_v2 |
|
0 |
0 |
5021 |
$is_v1 or $is_v2 or $is_v3 |
1884
|
2 |
0 |
0 |
&Compress::Snappy::decompress($Message->{'Value'}) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to decompress snappy compressed data') |
1963
|
2 |
0 |
0 |
gzip($message_set) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to compress gzip data') |
1966
|
2 |
0 |
0 |
&Compress::Snappy::compress($message_set) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to compress snappy data') |
2006
|
7 |
0 |
25147 |
$compression_codec // $Kafka::Protocol::COMPRESSION_NONE |