The Perl Toolchain Summit needs more sponsors. If your company depends on Perl, please support this very important event.

Changes for version 0.8010

  • CHANGES:
  • $RECEIVE_MAX_RETRIES, $SEND_MAX_RETRIES renamed to $RECEIVE_MAX_ATTEMPTS, $SEND_MAX_ATTEMPTS .
  • Method Kafka::Connection->is_server_alive renamed to is_server_connected .
  • New Kafka::Connection->is_server_alive method properly checks for availability of Kafka server.
  • Added method Kafka::Connection->get_metadata .
  • Added method Kafka::Connection->exists_topic_partition .
  • $Kafka::MIN_BYTES_RESPOND_HAS_DATA changed to 10.
  • Testing supports Kafka version 0.8.2 . BUGFIXES:
  • Partititon cannot be negative.
  • Improved reporting for ERROR_UNKNOWN_TOPIC_OR_PARTITION error.
  • Receiving metadata for a new topic fixed.

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.