orka.startup.infrastructure.kafka module

Kafka Infrastructure Management

This module handles Kafka Docker services management including orchestration and schema registry initialization.

orka.startup.infrastructure.kafka.start_kafka_docker() → None

Start Kafka services using Docker Compose.

Raises:

• subprocess.CalledProcessError – If Docker Compose commands fail

• FileNotFoundError – If docker directory cannot be found

orka.startup.infrastructure.kafka.wait_for_kafka_services() → None

Wait for Kafka services to be ready and responsive.

Raises:

RuntimeError – If Kafka services fail to become ready

orka.startup.infrastructure.kafka.initialize_schema_registry() → None

Initialize schema registry by creating a temporary KafkaMemoryLogger. This ensures schemas are registered at startup time.

orka.startup.infrastructure.kafka.cleanup_kafka_docker() → None

Clean up Kafka Docker services.

orka.startup.infrastructure.kafka.get_kafka_services() → List[str]

Get the list of Kafka service names.

Returns:

List of Kafka service names

Return type:

List[str]