pykafka.common¶
Author: Keith Bourgoin
-
class
pykafka.common.
Message
¶ Bases:
object
Message class.
Variables:
-
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)