| 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) |