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 Connectors
    • Connector
    • MTConnect Connector
    • OPC UA Connector
  • OpenFactory Apps
    • OpenFactoryApp
    • OpenFactory supervisors
      • BaseSupervisor
      • OPCUASupervisor
  • OpenFactory Storage
    • FileBackend Storage
    • LocalBackend Storage Backend
    • NFSBackend Storage Backend
  • Kafka related classes
    • Kafka consumers
      • KafkaAssetConsumer
      • KafkaAssetUNSConsumer
      • KafkaCommandsConsumer
    • AssetProducer
    • KSQLDBClient
    • KafkaLogger
    • CaseInsensitiveDict
  • OpenFactory Schemas
    • OpenFactory Shared Schemas
    • OpenFactory Infrastructure Schemas
    • OpenFactory Devices Schemas
    • OpenFactory Unified Namespace Schemas
    • OpenFactory Connectors Schemas
      • Types Module
      • Mtconnect Connector Schemas
      • OPC UA Connector Schemas
    • OpenFactory Supervisor Schemas
    • OpenFactory Applications Schemas
    • OpenFactory Storage Schemas
      • Types
      • Storage Backend Schema
      • Base Backend
      • Local Backend
      • NFS Backend
  • 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 consumers

Kafka consumers#

  • KafkaAssetConsumer
    • KafkaAssetConsumer
  • KafkaAssetUNSConsumer
    • KafkaAssetUNSConsumer
  • KafkaCommandsConsumer
    • KafkaCommandsConsumer
Edit on GitHub

© Copyright 2025, OpenFactory contributors.

Created using Sphinx 8.2.3.

Built with the PyData Sphinx Theme 0.16.1.