++ed by:

4 PAUSE users
2 non-PAUSE users.

Sergey Gladkov
and 1 contributors


  • Kafka - constants and messages used by the Kafka package modules
  • Kafka::Consumer - object interface to the consumer client
  • Kafka::IO - object interface to socket communications with the Apache Kafka 0.7 server without using the Apache ZooKeeper
  • Kafka::Int64 - functions to work with 64 bit elements of the Apache Kafka Wire Format protocol on 32 bit systems
  • Kafka::Message - object interface to the Kafka message properties
  • Kafka::Mock - object interface to the TCP mock server for testing
  • Kafka::Producer - object interface to the producer client
  • Kafka::Protocol - functions to process messages in the Apache Kafka's 0.7 Wire Format