pytest_kafka.constants module

Config templates and constants.

pytest_kafka.constants.DEFAULT_CONSUMER_TIMEOUT_MS = 500

Kafka Consumer timeout in miliseconds.

pytest_kafka.constants.KAFKA_SERVER_CONFIG_TEMPLATE = 'reserved.broker.max.id=65535\nbroker.id={kafka_port}\nlisteners=PLAINTEXT://:{kafka_port}\nlog.dirs={kafka_log_dir}\nnum.partitions=1\n# The number of threads lowered to 1 - may boost startup time:\nnum.recovery.threads.per.data.dir=1\nnum.network.threads=1\nnum.io.threads=1\nlog.retention.hours=1\nlog.segment.bytes=1073741824\nzookeeper.connect=localhost:{zk_port}\nzookeeper.connection.timeout.ms=6000\noffsets.topic.replication.factor=1\ndefault.replication.factor=1\n'

Kafka config template. kafka_log_dir, `kafka_port, and zk_port keys are required.

pytest_kafka.constants.ZOOKEEPER_CONFIG_TEMPLATE = 'dataDir={zk_data_dir}\nclientPort={zk_port}\nmaxClientCnxns=0\nadmin.enableServer=false\n'

Zookeeper config template. zk_data_dir and zk_port keys are required.