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()