---

iso_doc_type: "Specification" iso_viewpoint: "ComponentView" type: "module" title: "factory-infrastructure::kafka — Kafka Client" source_path: "crates/factory-infrastructure/src/kafka.rs" description: "ISO 42010 ComponentView / ISO 15289 Specification documentation for factory-infrastructure::kafka — Kafka Client." tags: ['iso42010', 'okf', 'component_view', 'rust', 'ast'] timestamp: "2026-10-01T14:00:00Z" generated: "agent:okf-professional-documenter" verified: "true" last_verified_commit: "fbdc5848"

factory-infrastructure::kafka — Kafka Client

Source: crates/factory-infrastructure/src/kafka.rs Layer: Infrastructure

---

KRaft-based Kafka producer/consumer with topic management, message serialization, and the KafkaClient trait for dependency injection in tests. Includes SimpleMockKafkaClient for unit testing.

---

Related: lib.rs · Infrastructure Adapters