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_5

  • CHANGES:
  • Test t/??_io.t checks the external ALRM signal handler.
  • Minor improvements in documentation.

Changes for version 0.800_4

  • CHANGES:
  • Refactored error handling. See documentation for module Kafka::Exceptions. Retired methods RaiseError, last_error last_errorcode.
  • Added method Kafka::Connection->cluster_errors.

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_17

  • CHANGES:
  • 'AutoCreateTopicsEnable' argument is added to Kafka::Connection->new (thanks to Ed Silva).

Changes for version 0.800_16

  • BUGFIXES:
  • Fixed problem with connecting to servers running on localhost.

Changes for version 0.800_15

  • CHANGES:
  • Improvement of test t/*_io.t .

Changes for version 0.800_14

  • CHANGES:
  • We use alarm internally in Kafka::IO (not Time::HiRes::alarm).
  • For 'gethostbyname' operations the timeout is rounded to the nearest greater positive integer.

Changes for version 0.8001_1

  • CHANGES:
  • t/*_io.t examines possibility of using gethostbyname( 'localhost' ) .
  • Debug diagnostic and test improved. BUGFIXES:
  • 'localhost' is no longer used in the t/*_io.t .

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 Kafka consumer client.
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.
Constants and functions used internally.
Interface to the Kafka message properties.
Perl interface for Kafka producer client.
Functions to process messages in the Apache Kafka protocol.