Changes for version 1.02

  • Special thanks to Damien Krotkine for API versioning implementation.
  • CHANGES:
  • Added API versioning support with auto-detection.
  • Timestamps in messages.
  • Improvements in offset methods: to be able to query offsets in an easier, simpler and more complete way (including support for version 0 and version 1 of message formats)
  • Support for array of keys in Kafka::Producer->send with array of messages.
  • BUGFIXES:
  • Improved timeouts handling for big payloads in Kafka::IO.

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.