基于Kafka的通信架构：面向近实时、云复制的闭环制造过程控制
A Kafka-Centric Communication Fabric for Near-Real-Time, Cloud-Replicated Closed-Loop Manufacturing Process Control
浏览论文内容
中文总结 AI 辅助
该研究提出基于Kafka等标准组件的通信架构，通过四个设计选择实现近实时闭环工业控制，支持云复制与边缘权威，保证网络中断时本地控制持续运行。
中文摘要 AI 辅助
智能制造需要将传感器数据从工厂车间移出，在限定时间内对其进行响应，并将决策反馈给执行器。可编程逻辑控制器（PLC）处理快速、确定性、安全关键的执行任务，但它们并非为工业4.0所需的更高级功能而设计，如预测性维护、机器学习推理和跨工厂分析。这些功能需要一个可扩展、持久且可观测的通信基础。我们展示了一个生产系统的通信架构，该系统提供了这一基础，并以近实时的方式将控制回路闭环回工厂。该设计基于行业标准组件构建：Apache Kafka作为流媒体骨干，OPC-UA用于PLC连接，关系型时序数据库用于持久化，JSON用于序列化。其新颖性在于架构层面。我们展示了如何通过四个设计选择将这些标准集成用于闭环工业控制：每条生产线的单一事件流服务于控制、监控、机器学习和持久记录，允许一个生产者服务多个独立消费者；一个协议桥接器将轮询的OPC-UA流量转换为发布/订阅流，将每个信号的时戳对齐到公共时间基准以消除跨信号抖动，并提供对称的执行路径；一种传输技术通过将带时戳的样本打包到固定顺序数组中，以较粗的发布节奏承载亚秒级过程动态；以及一种边缘到云的复制方案保持边缘权威性，因此在大范围网络中断期间本地控制继续运行，而云分析则对复制的数据进行操作。我们描述了回路延迟预算，报告了实测的代理传输延迟，并讨论了运行经验。该系统提供软性的近实时行为，而非硬实时保证。
英文摘要
Smart manufacturing needs to move sensor data off the plant floor, react to it, and feed decisions back to actuators within bounded time. Programmable logic controllers (PLCs) handle fast, deterministic, safety-critical actuation, but they are not designed for the higher-level functions required by Industry 4.0, such as predictive maintenance, machine learning inference, and cross-facility analytics. These functions need a scalable, durable, and observable communication substrate. We present the communication architecture of a production system that provides this substrate and closes the loop back to the plant in near real time. The design is built from industry-standard components: Apache Kafka as the streaming backbone, OPC-UA for PLC connectivity, a relational time-series database for persistence, and JSON for serialization. The novelty is architectural. We show how these standards are integrated for closed-loop industrial control through four design choices: a single event stream per production line serves control, monitoring, machine learning, and durable recording, allowing one producer to serve many independent consumers; a protocol bridge converts polled OPC-UA traffic into publish/subscribe streams, aligns per-signal timestamps to a common time base to remove cross-signal jitter, and provides a symmetric actuation path; a transport technique carries sub-second process dynamics at a coarser publication cadence by packing timestamped samples into fixed-order arrays; and an edge-to-cloud replication scheme keeps the edge authoritative, so local control continues during wide-area network outages while cloud analytics operate on replicated data. We describe the loop latency budget, report measured broker transport latency, and discuss operational experience. The system provides soft, near-real-time behavior rather than hard real-time guarantees.
发表机构
- Liveline Technologies
机构由 AI 辅助整理，请以论文原文为准。
