| /dports/net/p5-Kafka/Kafka-0.8010/t/ |
| H A D | 50_debug_level.t | 30 use Kafka::Connection;
31 use Kafka::IO;
36 my $DEBUG_Connection = $Kafka::Connection::DEBUG;
37 my $DEBUG_IO = $Kafka::IO::DEBUG;
43 package Kafka::TestDebugLevel;
49 use Kafka::Internals qw(
71 $Kafka::TestDebugLevel::DEBUG = 0;
73 $Kafka::TestDebugLevel::DEBUG = 1;
168 my $obj = Kafka::TestDebugLevel->new;
182 $Kafka::Connection::DEBUG = $DEBUG_Connection;
[all …]
|
| H A D | 03_mockio.t | 39 use Kafka qw(
43 use Kafka::MockIO;
44 use Kafka::TestInternals qw(
85 Kafka::MockIO::override();
90 Kafka::MockIO::restore();
95 Kafka::MockIO::override();
117 $io = Kafka::IO->new(
140 $io = Kafka::IO->new(
192 $io = Kafka::IO->new(
207 $io = Kafka::IO->new(
[all …]
|
| H A D | 11_consumer.t | 42 use Kafka qw(
55 use Kafka::Cluster;
56 use Kafka::Connection;
57 use Kafka::Consumer;
58 use Kafka::MockIO;
59 use Kafka::Producer;
60 use Kafka::TestInternals qw(
101 $consumer = Kafka::Consumer->new(
118 $consumer = Kafka::Consumer->new(
204 Kafka::MockIO::override();
[all …]
|
| H A D | 10_producer.t | 42 use Kafka qw(
52 use Kafka::Cluster;
53 use Kafka::Connection;
54 use Kafka::MockIO;
55 use Kafka::Producer;
56 use Kafka::TestInternals qw(
96 $producer = Kafka::Producer->new(
121 $producer = Kafka::Producer->new(
168 Kafka::MockIO::override();
180 $producer = Kafka::Producer->new(
[all …]
|
| H A D | 91_mock_usage.t | 38 use Kafka qw(
46 use Kafka::Connection;
47 use Kafka::Consumer;
48 use Kafka::Producer;
50 use Kafka::MockIO;
70 Kafka::MockIO::override();
74 dies_ok { $connect = Kafka::Connection->new(
80 $connect = Kafka::Connection->new(
88 dies_ok { $producer = Kafka::Producer->new(
93 lives_ok { $producer = Kafka::Producer->new(
[all …]
|
| H A D | 20_kafka_usage.t | 47 use Kafka qw(
55 use Kafka::Cluster;
56 use Kafka::Connection;
57 use Kafka::Consumer;
58 use Kafka::Producer;
89 dies_ok { $connect = Kafka::Connection->new(
95 $connect = Kafka::Connection->new(
103 dies_ok { $producer = Kafka::Producer->new(
108 lives_ok { $producer = Kafka::Producer->new(
147 unless ( $connect = Kafka::Connection->new(
[all …]
|
| H A D | 42_nonfatal_errors.t | 39 use Kafka qw(
71 use Kafka::Connection qw(
74 use Kafka::Consumer;
75 use Kafka::Producer;
77 use Kafka::Internals qw(
82 use Kafka::MockProtocol qw(
87 use Kafka::Protocol qw(
93 use Kafka::MockIO;
97 Kafka::MockIO::override();
344 Kafka::MockIO::add_special_case(
[all …]
|
| H A D | 45_compression.t | 35 use Kafka qw(
44 use Kafka::Cluster;
45 use Kafka::Connection;
46 use Kafka::Consumer;
47 use Kafka::MockIO;
48 use Kafka::Producer;
49 use Kafka::TestInternals qw(
57 my $cluster = Kafka::Cluster->new(
77 $connect = Kafka::Connection->new(
84 $producer = Kafka::Producer->new(
[all …]
|
| H A D | 41_fork.t | 45 use Kafka qw(
49 use Kafka::Cluster qw(
52 use Kafka::Connection;
53 use Kafka::MockIO;
54 use Kafka::Consumer;
55 use Kafka::Producer;
61 my $cluster = Kafka::Cluster->new(
193 $producer = Kafka::Producer->new(
198 $consumer = Kafka::Consumer->new(
213 $producer = Kafka::Producer->new(
[all …]
|
| H A D | 08_connection.t | 43 use Kafka qw(
62 use Kafka::Cluster;
63 use Kafka::Connection;
64 use Kafka::Internals qw(
70 use Kafka::MockIO;
71 use Kafka::TestInternals qw(
145 Kafka::MockIO::override();
395 Kafka::MockIO::restore()
402 Kafka::MockIO::override();
403 my $method = \&Kafka::IO::send;
[all …]
|
| H A D | 90_mock_io.t | 36 use Kafka qw(
49 use Kafka::Internals qw(
56 use Kafka::MockIO;
57 use Kafka::MockProtocol qw(
60 use Kafka::Protocol qw(
77 const my $PARTITION => $Kafka::MockIO::PARTITION;
96 Kafka::MockIO::override();
98 $io = Kafka::IO->new(
166 Kafka::MockIO::add_special_case( { $encoded_request => $encoded_response } );
172 Kafka::MockIO::del_special_case( $encoded_request );
[all …]
|
| H A D | 43_competition.t | 52 use Kafka qw(
57 use Kafka::Cluster;
58 use Kafka::Connection;
59 use Kafka::Consumer;
60 use Kafka::Internals qw(
63 use Kafka::MockIO;
64 use Kafka::Producer;
365 $cluster = Kafka::Cluster->new(
393 $cluster = Kafka::Cluster->new(
407 $producer = Kafka::Producer->new(
[all …]
|
| H A D | 02_io.t | 54 use Kafka qw(
58 use Kafka::IO;
59 use Kafka::TestInternals qw(
72 Kafka::IO->debug_level( DEBUG ) if DEBUG;
144 $io = Kafka::IO->new(
153 $io = Kafka::IO->new(
189 $io = Kafka::IO->new(
227 $io = Kafka::IO->new(
276 $io = Kafka::IO->new(
296 $io = Kafka::IO->new(
[all …]
|
| H A D | 40_autocreate_topics.t | 56 use Kafka qw(
61 use Kafka::Cluster qw(
64 use Kafka::Connection;
65 use Kafka::Consumer;
66 use Kafka::MockIO;
67 use Kafka::Producer;
145 $partition = $Kafka::MockIO::PARTITION;;
153 $cluster = Kafka::Cluster->new(
163 $connection = Kafka::Connection->new(
168 $producer = Kafka::Producer->new(
[all …]
|
| H A D | 44_bad_sending.t | 40 use Kafka::Cluster;
44 use Kafka qw(
51 use Kafka::Connection;
52 use Kafka::Consumer;
53 use Kafka::Producer;
65 const my $HOST => $Kafka::Cluster::HOST;
103 my $original_send = \&Kafka::IO::send;
299 $cluster = Kafka::Cluster->new(
306 $connection = Kafka::Connection->new(
310 $producer = Kafka::Producer->new(
[all …]
|
| /dports/net/p5-Kafka/Kafka-0.8010/ |
| H A D | META.yml | 46 name: Kafka
54 Kafka:
57 Kafka::Connection:
60 Kafka::Consumer:
63 Kafka::Exceptions:
66 Kafka::IO:
69 Kafka::Int64:
72 Kafka::Internals:
75 Kafka::Message:
78 Kafka::Producer:
[all …]
|
| H A D | Changes | 1 Revision history for Kafka package
9 for availability of Kafka server.
13 - Testing supports Kafka version 0.8.2 .
57 Kafka::Connection->clear_nonfatals, Kafka::Internals->debug_level .
87 alarm used by Kafka::IO.
93 Kafka::Connection->new or Kafka::IO->new. In this case '$REQUEST_TIMEOUT'
125 - Implement Kafka API ver 0.8.0 . For communication with earlier versions of Kafka
127 - Added Kafka::Connection, Kafka::Internals.
128 - Kafka::Mock renamed to Kafka::MockIO and moved to t/lib.
130 Kafka::Cluster, Kafka::MockProtocol, Kafka::TestInternals.
[all …]
|
| H A D | README | 1 Kafka package version 0.8010
4 The Kafka package is a set of Perl modules which provides a
8 and functions that allow you to write Apache Kafka clients.
29 Kafka:
95 # The root directory of the installation Kafka 0.8
112 The basic operation of the Kafka package modules:
114 Kafka - constants and messages used by the Kafka package.
118 Kafka::Message - interface to the Kafka message properties.
122 Apache Kafka's Protocol.
123 Kafka::IO - low-level communications with the Apache Kafka server.
[all …]
|
| H A D | MANIFEST | 7 lib/Kafka.pm
8 lib/Kafka/Connection.pm
9 lib/Kafka/Consumer.pm
11 lib/Kafka/IO.pm
12 lib/Kafka/Int64.pm
13 lib/Kafka/Internals.pm
14 lib/Kafka/Message.pm
15 lib/Kafka/Producer.pm
16 lib/Kafka/Protocol.pm
17 t/lib/Kafka/Cluster.pm
[all …]
|
| /dports/net/p5-Kafka/Kafka-0.8010/t/lib/Kafka/ |
| H A D | MockIO.pm | 1 package Kafka::MockIO;
43 use Kafka qw(
53 use Kafka::Internals qw(
60 use Kafka::IO;
61 use Kafka::MockProtocol qw(
138 new => [ \&Kafka::IO::new, \&new ],
139 send => [ \&Kafka::IO::send, \&send ],
141 close => [ \&Kafka::IO::close, \&close ],
446 Kafka::IO::_debug_msg( $self, $message, 'Request to', 'green' )
447 if Kafka::IO->debug_level == 1;
[all …]
|
| /dports/net/p5-Kafka/Kafka-0.8010/tools/ |
| H A D | profiling.pl | 36 use Kafka qw (
41 use Kafka::Cluster;
42 use Kafka::Connection;
43 use Kafka::Consumer;
44 use Kafka::MockIO;
45 use Kafka::Producer;
46 use Kafka::TestInternals;
58 $topic = $Kafka::TestInternals::topic;
59 $partition = $Kafka::MockIO::PARTITION;
134 ( $port ) = Kafka::Cluster->new(
[all …]
|
| /dports/devel/py-oslo.messaging/oslo.messaging-12.11.0/doc/source/admin/ |
| H A D | kafka.rst | 2 Kafka Driver Deployment Guide
8 The Kafka Driver is an experimental messaging transport backend
11 Apache Kafka distributed streaming platform. More detail regarding
12 the Apache Kafka server is available from the `Apache Kafka website`__.
27 *oslo.messaging* notifications. Specifically, the Kafka driver
35 a clustered Kafka server deployment.
58 The Kafka topic is the feed name to which records are
63 Kafka topic. The Kafka server architecture does not natively support
68 control or isolation provided by the Kafka server.
95 replay messages from a Kafka partition.
[all …]
|
| /dports/net/librdkafka/librdkafka-1.8.2/debian/ |
| H A D | control | 16 Description: library implementing the Apache Kafka protocol
17 librdkafka is a C library implementation of the Apache Kafka protocol,
23 More information about Apache Kafka can be found at http://kafka.apache.org/
31 Description: library implementing the Apache Kafka protocol (C++ bindings)
32 librdkafka is a C library implementation of the Apache Kafka protocol,
38 More information about Apache Kafka can be found at http://kafka.apache.org/
48 librdkafka is a C library implementation of the Apache Kafka protocol,
54 More information about Apache Kafka can be found at http://kafka.apache.org/
64 Description: library implementing the Apache Kafka protocol (debugging symbols)
65 librdkafka is a C implementation of the Apache Kafka protocol. It currently
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/debian/ |
| H A D | control | 16 Description: library implementing the Apache Kafka protocol
17 librdkafka is a C library implementation of the Apache Kafka protocol,
23 More information about Apache Kafka can be found at http://kafka.apache.org/
31 Description: library implementing the Apache Kafka protocol (C++ bindings)
32 librdkafka is a C library implementation of the Apache Kafka protocol,
38 More information about Apache Kafka can be found at http://kafka.apache.org/
48 librdkafka is a C library implementation of the Apache Kafka protocol,
54 More information about Apache Kafka can be found at http://kafka.apache.org/
64 Description: library implementing the Apache Kafka protocol (debugging symbols)
65 librdkafka is a C implementation of the Apache Kafka protocol. It currently
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/debian/ |
| H A D | control | 16 Description: library implementing the Apache Kafka protocol
17 librdkafka is a C library implementation of the Apache Kafka protocol,
23 More information about Apache Kafka can be found at http://kafka.apache.org/
31 Description: library implementing the Apache Kafka protocol (C++ bindings)
32 librdkafka is a C library implementation of the Apache Kafka protocol,
38 More information about Apache Kafka can be found at http://kafka.apache.org/
48 librdkafka is a C library implementation of the Apache Kafka protocol,
54 More information about Apache Kafka can be found at http://kafka.apache.org/
64 Description: library implementing the Apache Kafka protocol (debugging symbols)
65 librdkafka is a C implementation of the Apache Kafka protocol. It currently
[all …]
|