| line |
true |
false |
branch |
|
74
|
0 |
0 |
unless $self->brik_help_run_undef_arg('create_connection', $host) |
|
75
|
0 |
0 |
unless $self->brik_help_run_invalid_arg('create_connection', $host, 'ARRAY') |
|
76
|
0 |
0 |
unless $self->brik_help_run_empty_array_arg('create_connection', $host) |
|
85
|
0 |
0 |
unless (defined $server and defined Kafka::Connection::_STRING($server) and $server =~ /^[^:]+:\d+$/) |
|
118
|
0 |
0 |
if ($@) |
|
131
|
0 |
0 |
unless my $kc = $self->create_connection |
|
145
|
0 |
0 |
if ($@) |
|
157
|
0 |
0 |
unless my $kc = $self->create_connection |
|
163
|
0 |
0 |
if ($@) |
|
176
|
0 |
0 |
unless $self->brik_help_run_undef_arg('create_producer', $kcli) |
|
178
|
0 |
0 |
unless $self->brik_help_run_undef_arg('send', $topic) |
|
179
|
0 |
0 |
unless $self->brik_help_run_undef_arg('send', $partition) |
|
180
|
0 |
0 |
unless $self->brik_help_run_undef_arg('send', $messages) |
|
181
|
0 |
0 |
unless $self->brik_help_run_invalid_arg('send', $messages, 'ARRAY', 'SCALAR') |
|
189
|
0 |
0 |
if ($@) |
|
212
|
0 |
0 |
if ($@ =~ /^$no_ack_for_request/i) { } |
|
|
0 |
0 |
elsif ($@ =~ /^$cant_connect/i) { } |
|
|
0 |
0 |
elsif ($@ =~ /^$cant_get_metadata/i) { } |
|
|
0 |
0 |
elsif ($@ =~ /^$unable_to_write/i) { } |
|
|
0 |
0 |
elsif ($@ =~ /^$no_known_broker/i) { } |
|
|
0 |
0 |
elsif ($@ =~ /^$too_big/i) { } |
|
|
0 |
0 |
elsif ($@ =~ /^$invalid_arg_messages/i) { } |
|
247
|
0 |
0 |
unless $self->brik_help_run_undef_arg('create_consumer', $kcli) |
|
248
|
0 |
0 |
unless $self->brik_help_run_undef_arg('loop_consumer_fetch', $topic) |
|
270
|
0 |
0 |
if ($message->valid) { } |
|
287
|
0 |
0 |
if ($self->_kcli) |
|
291
|
0 |
0 |
if ($self->_kc) |
|
305
|
0 |
0 |
unless $self->brik_help_run_undef_arg('create_topic', $topic) |
|
323
|
0 |
0 |
unless $self->brik_help_run_undef_arg('alter_topic', $topic) |
|
340
|
0 |
0 |
unless $self->brik_help_run_undef_arg('delete_topic', $topic) |
|
370
|
0 |
0 |
unless $self->brik_help_run_undef_arg('describe_topic', $topic) |
|
392
|
0 |
0 |
unless $self->brik_help_run_undef_arg('run_console_producer', $topic) |
|
408
|
0 |
0 |
unless $self->brik_help_run_undef_arg('run_console_consumer', $topic) |