pykafka.common

Author: Keith Bourgoin

class pykafka.common.Message

Bases: object

Message class.

Variables:
  • response_code – Response code from Kafka
  • topic – Originating topic
  • payload – Message payload
  • key – (optional) Message key
  • offset – Message offset
class pykafka.common.CompressionType

Bases: object

Enum for the various compressions supported.

Variables:
  • NONE – Indicates no compression in use
  • GZIP – Indicates gzip compression in use
  • SNAPPY – Indicates snappy compression in use
  • LZ4 – Indicates lz4 compression in use
__weakref__

list of weak references to the object (if defined)

class pykafka.common.OffsetType

Bases: object

Enum for special values for earliest/latest offsets.

Variables:
  • EARLIEST – Indicates the earliest offset available for a partition
  • LATEST – Indicates the latest offset available for a partition
__weakref__

list of weak references to the object (if defined)