| line |
true |
false |
branch |
|
219
|
20 |
88 |
unless &_INSTANCE($self->{'Connection'}, 'Kafka::Connection') |
|
221
|
8 |
80 |
unless $self->{'ClientId'} eq '' || defined &_STRING($self->{'ClientId'}) and not utf8::is_utf8($self->{'ClientId'}) |
|
223
|
0 |
70 |
unless defined &_NUMBER($self->{'Timeout'}) and int $self->{'Timeout'} * 1000 >= 1 and int $self->{'Timeout'} * 1000 <= $Kafka::Producer::MAX_INT32 |
|
226
|
10 |
58 |
unless defined $required_acks and &isint($required_acks) and $required_acks == $Kafka::Producer::NOT_SEND_ANY_RESPONSE || $required_acks == $Kafka::Producer::WAIT_WRITTEN_TO_LOCAL_LOG || $required_acks == $Kafka::Producer::BLOCK_UNTIL_IS_COMMITTED |
|
302
|
8 |
5062 |
unless defined $topic and $topic eq '' || defined &_STRING($topic) and not utf8::is_utf8($topic) |
|
304
|
10 |
5052 |
unless defined $partition and &isint($partition) and $partition >= 0 |
|
306
|
5 |
5047 |
unless defined &_STRING($messages) or &_ARRAY($messages) |
|
308
|
6 |
22 |
unless not defined $keys or defined &_STRING($keys) or &_ARRAY($keys) |
|
311
|
12 |
3 |
unless not defined $compression_codec or $known_compression_codecs{$compression_codec} |
|
313
|
8 |
5021 |
unless ref $messages |
|
315
|
9 |
10033 |
unless defined $message and $message eq '' || defined &_STRING($message) && !utf8::is_utf8($message) |
|
321
|
0 |
5020 |
if (&_ARRAY($keys)) { } |
|
|
1 |
5019 |
elsif (defined $keys) { } |
|
323
|
0 |
0 |
unless scalar @$keys == scalar @$messages |
|
327
|
0 |
0 |
unless not defined $key or $key eq '' or defined &_STRING($key) and not utf8::is_utf8($key) |
|
332
|
1 |
0 |
unless $keys eq '' or defined &_STRING($keys) and not utf8::is_utf8($keys) |
|
362
|
10032 |
0 |
defined $common_key ? : |