Skip to main content
Ctrl+K

OpenFactory

  • About
  • API Reference
  • GitHub
  • About
  • API Reference
  • GitHub

Section Navigation

  • OpenFactory Core API
    • OpenFactory
    • OpenFactoryManager
    • OpenFactoryCluster
    • OpenFactory Deployment Strategies
  • OpenFactory Assets
    • BaseAsset
    • Asset
    • AssetUNS
    • Asset Utils
  • OpenFactory Apps
    • OpenFactoryApp
    • OpenFactory supervisors
  • Kafka related classes
    • Kafka consumers
    • AssetProducer
    • KSQLDBClient
    • KafkaLogger
    • CaseInsensitiveDict
  • OpenFactory Schemas
    • OpenFactory Infrastructure Schemas
    • OpenFactory Devices Schemas
    • OpenFactory Applications Schemas
    • OpenFactory Unified Namespace Schemas
  • OpenFactory Utils Module
    • OpenFactory Utils Module - General functions
    • OpenFactory Utils Module - Asset registration
    • OpenFactory Utils Module - Open URIS
    • OpenFactory Utils Module - GitHub Token Store
  • Exceptions
  • API Reference
  • Kafka related classes

Kafka related classes#

  • Kafka consumers
    • KafkaAssetConsumer
    • KafkaAssetUNSConsumer
    • KafkaCommandsConsumer
  • AssetProducer
    • AssetProducer
  • KSQLDBClient
    • KSQLDBClient
    • KSQLDBClientException
  • KafkaLogger
    • KafkaLogger
  • CaseInsensitiveDict
    • CaseInsensitiveDict
Edit on GitHub

© Copyright 2025, OpenFactory contributors.

Created using Sphinx 8.2.3.

Built with the PyData Sphinx Theme 0.16.1.