pytest_kafka

• pytest_kafka package
  • make_kafka_consumer()
  • make_kafka_server()
  • make_zookeeper_process()
  • terminate()
  • Submodules
    • pytest_kafka.constants module
      • DEFAULT_CONSUMER_TIMEOUT_MS
      • KAFKA_SERVER_CONFIG_TEMPLATE
      • ZOOKEEPER_CONFIG_TEMPLATE
    • pytest_kafka.install module
      • clean_kafka()
      • expected_archive_root_dir()
      • set_up_kafka()