ApacheKafkaBroker

fastkafka.testing.ApacheKafkaBroker

ApacheKafkaBroker class, used for running unique kafka brokers in tests to prevent topic clashing.

__init__

def __init__(self, topics: Iterable[str] = [], retries: int = 3, apply_nest_asyncio: bool = False, zookeeper_port: int = 2181, listener_port: int = 9092) -> None

Initialises the ApacheKafkaBroker object

Parameters:

• data_dir: Path to the directory where the zookeepeer instance will save data
• zookeeper_port: Port for clients (Kafka brokes) to connect
• listener_port: Port on which the clients (producers and consumers) can connect

start

def start(self: fastkafka.testing.ApacheKafkaBroker) -> str

Starts a local kafka broker and zookeeper instance synchronously

Returns:

• Kafka broker bootstrap server address in string format: add:port

stop

def stop(self: fastkafka.testing.ApacheKafkaBroker) -> None

Stops a local kafka broker and zookeeper instance synchronously

Returns:

• None