Kafka Manager
  • Usage Overview
  • kafka-manager API
    • KafkaManager
    • KafkaProducerClient
    • KafkaConsumerClient
  • Installation
  • Tests
  • License
Kafka Manager
  • kafka-manager API
  • View page source

kafka-manager API

  • KafkaManager
    • KafkaManager
      • KafkaManager.admin_client
      • KafkaManager.close()
      • KafkaManager.close_admin_client()
      • KafkaManager.connect_admin_client()
      • KafkaManager.consume_messages()
      • KafkaManager.consumers
      • KafkaManager.create_consumer()
      • KafkaManager.create_topic()
      • KafkaManager.delete_topic()
      • KafkaManager.is_producer_running()
      • KafkaManager.producer_client
      • KafkaManager.send_message()
      • KafkaManager.start_consumer()
      • KafkaManager.start_producer()
      • KafkaManager.stop_all_consumers()
      • KafkaManager.stop_consumer()
      • KafkaManager.stop_producer()
  • KafkaProducerClient
    • KafkaProducerClient
      • KafkaProducerClient.flush()
      • KafkaProducerClient.is_producer_running()
      • KafkaProducerClient.send_message()
      • KafkaProducerClient.start()
      • KafkaProducerClient.stop()
  • KafkaConsumerClient
    • KafkaConsumerClient
      • KafkaConsumerClient.consume()
      • KafkaConsumerClient.consumer
      • KafkaConsumerClient.is_running()
      • KafkaConsumerClient.start()
      • KafkaConsumerClient.stop()
Previous Next

© Copyright 2025, Anshuman Pattnaik.

Built with Sphinx using a theme provided by Read the Docs.