This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.3.

# Zookeeper Transport - `kombu.transport.zookeeper`

Zookeeper transport module for kombu.

Zookeeper based transport. This transport uses the built-in kazoo Zookeeper based queue implementation.

References

- https://zookeeper.apache.org/doc/current/recipes.html#sc_recipes_Queues

- https://kazoo.readthedocs.io/en/latest/api/recipe/queue.html

Limitations This queue does not offer reliable consumption. An entry is removed from the queue prior to being processed. So if an error occurs, the consumer has to re-queue the item or it will be lost.

## Features

- Type: Virtual

- Supports Direct: Yes

- Supports Topic: Yes

- Supports Fanout: No

- Supports Priority: Yes

- Supports TTL: No

## Connection String

Connects to a zookeeper node as:

    zookeeper://SERVER:PORT/VHOST

The <vhost> becomes the base for all the other znodes. So we can use it like a vhost.

## Transport Options

## Transport

class kombu.transport.zookeeper.Transport(*args, **kwargs)

  Zookeeper Transport.

  class Channel(connection, **kwargs)

    Zookeeper Channel.

    property client
  channel_errors = (<class 'amqp.exceptions.ChannelError'>,)

    Tuple of errors that can happen due to channel/method failure.

  connection_errors = (<class 'amqp.exceptions.ConnectionError'>,)

    Tuple of errors that can happen due to connection failure.

  default_port = 2181

    port number used when no port is specified.

  driver_name = 'kazoo'

    Name of driver library (e.g. ‘py-amqp’, ‘redis’).

  driver_type = 'zookeeper'

    Type of driver, can be used to separate transports using the AMQP protocol (driver_type: ‘amqp’), Redis (driver_type: ‘redis’), etc…

  driver_version()
  polling_interval = 1

    Time to sleep between unsuccessful polls.

## Channel

class kombu.transport.zookeeper.Channel(connection, **kwargs)

  Zookeeper Channel.

  property client