Index

A | C | H | L | M | P | R | S | U

A

  • aiokafka.helpers
    • module
  • AIOKafkaConsumer (class in aiokafka)
  • AIOKafkaProducer (class in aiokafka)
  • assign() (aiokafka.AIOKafkaConsumer method)
  • assignment() (aiokafka.AIOKafkaConsumer method)

C

  • ConsumerRebalanceListener (class in aiokafka)
  • create_batch() (aiokafka.AIOKafkaProducer method)
  • create_ssl_context() (in module aiokafka.helpers)

H

  • highwater() (aiokafka.AIOKafkaConsumer method)

L

  • last_poll_timestamp() (aiokafka.AIOKafkaConsumer method)
  • last_stable_offset() (aiokafka.AIOKafkaConsumer method)

M

  • module
    • aiokafka.helpers

P

  • partitions_for_topic() (aiokafka.AIOKafkaConsumer method)
  • pause() (aiokafka.AIOKafkaConsumer method)
  • paused() (aiokafka.AIOKafkaConsumer method)

R

  • resume() (aiokafka.AIOKafkaConsumer method)

S

  • seek() (aiokafka.AIOKafkaConsumer method)
  • subscribe() (aiokafka.AIOKafkaConsumer method)
  • subscription() (aiokafka.AIOKafkaConsumer method)

U

  • unsubscribe() (aiokafka.AIOKafkaConsumer method)

aiokafka

Apache Kafka client for asyncio

https://secure.travis-ci.org/aio-libs/aiokafka.svg?branch=master

https://codecov.io/github/aio-libs/aiokafka/coverage.svg?branch=master

Navigation

  • Producer client
  • Consumer client
  • Difference between aiokafka and kafka-python
  • API Documentation
  • Examples

Quick search

©2015-2017, Aio-libs contributors. | Powered by Sphinx 3.1.1 & Alabaster 0.7.12
Fork me on GitHub