The London Perl and Raku Workshop takes place on 26th Oct 2024. If your company depends on Perl, please consider sponsoring and/or attending.

Changes for version 0.800_3

  • CHANGES:
  • Use Try::Tiny for proper preservation of $@ .

Changes for version 0.800_2

  • BUGFIXES:
  • Fixed to make it working on Perl 5.10 and over.

Changes for version 0.800_1

  • !!! This is a major upgrade that changes API. It's strongly advised to study revised documentation and update your code where necessary !!!
  • CHANGES:
  • Implement Kafka API ver 0.8. For communication with earlier versions of Kafka use Kafka module versions before 0.8.
  • added Kafka::Connection, Kafka::Internals.
  • Kafka::Mock renamed to Kafka::MockIO and moved to t/lib.
  • Additional testing units (in t/lib) for the following modules: Kafka::Cluster, Kafka::MockProtocol, Kafka::TestInternals.
  • Various service scripts & configurations added in t/bin and t/config.
  • Profiling scripts are added to the tools directory.
  • Introducted KAFKA_BASE_DIR environment variable to specify alternative location to Kafka base directory. Defaults to t/data.
  • Updated service files needed to build the package.

Modules

Apache Kafka interface for Perl
object interface to connect to a kafka cluster.
Perl interface for 'consumer' client.
interface to network communication with the Apache Kafka server.
functions to work with 64 bit elements of the protocol on 32 bit systems.
Constants and functions used internally.
interface to the Kafka message properties.
interface to the 'producer' client.
functions to process messages in the Apache Kafka protocol.