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