/ 
Kafka-1.02
River stage one • 2 direct dependents • 2 total dependents

Changes for version 1.02

  • 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.

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

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.
Kafka::IO
Interface to network communication with the Apache Kafka server.
Kafka::Int64
Functions to work with 64 bit elements of the protocol on 32 bit systems.
Kafka::Internals
Constants and functions used internally.
Kafka::Message
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