-
Notifications
You must be signed in to change notification settings - Fork 28
/
README
141 lines (114 loc) · 3.78 KB
/
README
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
Kafka package version 1.08
==============================
The Kafka package is a set of Perl modules which provides a
simple and consistent application programming interface (API) to the
Apache Kafka 0.9+, a high-throughput distributed messaging system.
The main focus of the package is to provide classes
and functions that allow you to write Apache Kafka clients.
The Kafka package was written, tested, and found working on
recent Linux distributions.
INSTALLATION
To install this package type the following:
perl Build.PL
./Build
./Build test
./Build install
DEPENDENCIES
In order to install and use this package you will need Perl version
5.010 or higher. Some modules within this package depend on other
packages that are distributed separately from Perl. We recommend that
you have the following packages installed before you install
Kafka:
Authen::SCRAM::Client
Carp
Compress::Snappy
Const::Fast
Data::Compare
Data::HexDump::Range
Data::Validate::Domain
Data::Validate::IP
Exception::Class
Exporter
Gzip::Faster
IO::Select
List::Util
Params::Util
Scalar::Util
Scalar::Util::Numeric
Socket
String::CRC32
Sys::SigAction
Time::HiRes
Try::Tiny
The Kafka package has the following optional dependencies:
Capture::Tiny
Carp
Clone
Config::IniFiles
Const::Fast
Cwd
Data::Dumper
Exporter
File::HomeDir
File::Path
File::Spec
File::Spec::Functions
IO::File
IO::Socket::INET
IO::Socket::IP
List::Util
Net::EmptyPort
Params::Util
Proc::Daemon
Scalar::Util
Scalar::Util::Numeric
Socket
Sub::Install
Sys::SigAction
Test::Deep
Test::Exception
Test::Fixme
Test::More
Test::NoWarnings
Test::TCP
Time::HiRes
Try::Tiny
If the optional modules are missing, some "prereq" tests are skipped.
The installation of the missing dependencies can either be accomplished
through your OS package manager or through CPAN (or downloading the source
for all dependencies and compiling them manually).
TESTING
The following environment variable changes the way Kafka Benchmark test behave:
# The root directory of the installation Kafka 0.9+
KAFKA_BASE_DIR
SIMPLE BENCHMARK
Use tools/benchmark_consumer.pl and tools/benchmark_producer.pl to run a simple
benchmark.
Run one or more consumer or producer instances using tools/benchmark_consumer.pl or
tools/benchmark_producer.pl .
DOCUMENTATION
Every Kafka package module has a man page. A simple description of each module is
included below in the SEE ALSO section.
SEE ALSO
The basic operation of the Kafka package modules:
Kafka - constants and messages used by the Kafka package.
Kafka::Connection - API to connect to a kafka cluster.
Kafka::Producer - interface to the 'producer' client.
Kafka::Consumer - interface to the 'consumer' client.
Kafka::Message - interface to the Kafka message properties.
Kafka::Int64 - functions to work with 64 bit elements of the
protocol on 32 bit systems.
Kafka::Protocol - functions to process messages in the
Apache Kafka's Protocol.
Kafka::IO - low-level communications with the Apache Kafka server.
Kafka::Exceptions - module designated to handle Kafka exceptions.
Kafka::Internals - Internal constants and functions used
by several packaged modules.
COPYRIGHT AND LICENCE
Copyright (C) 2012-2017 by TrackingSoft LLC.
This package is free software; you can redistribute it and/or modify it under
the same terms as Perl itself. See perlartistic at
http://dev.perl.org/licenses/artistic.html .
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
or FITNESS FOR A PARTICULAR PURPOSE.