Kafka-1.001013 - Apache Kafka low-level synchronous API, which does not use Zookeeper. - metacpan.org

Sergey Gladkov /

Kafka-1.001013

Changes for version 1.001013

CHANGES:
Removed support for custom CorrelationID in constructor arguments.
Use seconds for Consumer.MaxWaitTime to make it similar to Producer.Timeout.
Removed deprecated constants $RECEIVE_MAX_ATTEMPTS, $RECEIVE_MAX_RETRIES, $SEND_MAX_RETRIES.
Replaced Kafka::Connection->is_server_alive, Kafka::IO->is_alive with private methods (to be used for internal tests only).
BUGFIXES:
Fixed incorrect timeout values in requests.
Improved socket handling in Kafka::IO.

Modules

Kafka

Apache Kafka interface for Perl.

Kafka::Connection

Object interface to connect to a kafka cluster.

Kafka::Consumer

Perl interface for Kafka consumer client.

Kafka::Exceptions

Perl Kafka API exception definitions.

Interface to network communication with the Apache Kafka server.

Functions to work with 64 bit elements of the protocol on 32 bit systems.

Kafka::Internals

Constants and functions used internally.

Interface to the Kafka message properties.

Kafka::Producer

Perl interface for Kafka producer client.

Kafka::Protocol

Functions to process messages in the Apache Kafka protocol.

Other files

To install Kafka, copy and paste the appropriate command in to your terminal.

cpanm Kafka

perl -MCPAN -e shell
install Kafka

For more information on module installation, please visit the detailed CPAN module installation guide.

	Global
`s`	Focus search bar
`?`	Bring up this help dialog

	GitHub
`g` `p`	Go to pull requests
`g` `i`	go to github issues (only if github is preferred repository)

	POD
`g` `a`	Go to author
`g` `c`	Go to changes
`g` `i`	Go to issues
`g` `d`	Go to dist
`g` `r`	Go to repository/SCM
`g` `s`	Go to source
`g` `b`	Go to file browse

	Search terms
module: (e.g. module:Plugin)
distribution: (e.g. distribution:Dancer auth)
author: (e.g. author:SONGMU Redis)
version: (e.g. version:1.00)