.png){kind=logo}
Apache Kafka插件
连接Apache Kafka数据库
来自 Apache 基金会 的 Apache Kafka 软件是一款用于流式传输数据包的免费软件。 Kafka 系统由连接和互连的集群组成，以提供消息系统，允许数据从发送者（生产者）无损传输到接收者（消费者）。系统按照发布/订阅的逻辑工作。经纪人为消费者保存数据，以便客户可以控制处理。消息的顺序保持不变。消息在 Kafka 中使用主题和可选的密钥进行标记。发送的消息包含一个未提供格式的有效负载，类似于 MQTT。
。
就是这么容易。
通过拖放连接 Apache Kafka
通过OPC Router使用拖放操作非常简单直观的就可以连接到Apache Kafka数据库。这两个屏幕截图向您展示了 Kafka 应用程序的示例。在第一个屏幕截图中，在 KepServerEX 的帮助下获取数据，将其转换为 JSON 并发送到 Apache Kafka Broker。第二个屏幕截图显示了如何从 Apache Kafka 接收数据、在 JSON 中进行评估并传输到 MS-SQL 数据库。
将工业 4.0 带入生活
- 通过耦合系统实现更多目标：
耦合系统可以实时交换信息，从而立即适应所有需求。通过包含和查看所有可用信息，可以消除等待时间和效率低下的问题。 - Apache Kafka 的工业 4.0：
工业 4.0 意味着基于信息的工厂的最佳联网、自我控制和自我优化。Apache Kafka 提供了大规模实现这一目标的必要基础设施。 - 关于 OPC Router：
OPC Router为工业系统与 Apache Kafka 提供了强大的链接。其图形化配置和强大的运行时间使其成为工业应用的理想选择。
Apache Kafka 插件应用示例
跨所有工厂的主数据分布
对于许多流程，物料主数据是单个生产流程参数化的重要基础。为了快速和自主地做出决定，这些数据作为影子副本保存在工厂附近，以避免在检索中央数据时出现问题和延迟。使用 Apache Kafka，主数据可以安全地提供给所有感兴趣的“消费者”。循环传输，例如作为 JSON 包， 确保当前状态始终直接在工厂的数据库中可用。不依赖中央系统。当前的生产参数也可以以相同的方式从工厂传回，从而可以集中进行智能评估和处理（大数据/人工智能）。
过程数据流
Kafka 提供了高度的 安全性和 对连接问题的 容忍度，以便 在大地理距离和各种网络架构上进行中央监控。如果使用 OPC Router将当前状态/故障和运行时信息从系统传输到 Kafka，则集群系统可确保将 数据正确且无缝地传输 到中央监控系统。与 MQTT 等轻量级物联网基础设施相比， Kafka 确保可靠传输，这是工业消息传递系统所必需的。
使用 OPC Router Apache Kafka 插件连接系统
触发
如果 OPC Router应充当 Kafka 消费者，则使用 Kafka 触发器。为触发器配置的主题，OPC Router使用该主题在 Kafka 中注册为订阅者。只要有新消息可用于该主题，触发器就会激活其配置的连接。如果有几条消息可用，则为每条消息重新触发触发器。即使在系统重新启动后，触发器也会检索尚未从代理检索到的所有消息。
浏览
在传输对象和触发器中可以浏览代理中的主题。成功配置代理连接后，将加载可用主题并以列表形式供操作员访问以供选择。