帮助中心帮助中心

事件流处理

读写事件，比如卡夫卡^®事件

当您安装MATLAB流数据框架^®生产服务器™,您可以:

从事件流平台(如Kafka)读取和写入事件流。
模拟生产环境来测试你的流分析算法。(需要MATLAB编译器SDK™)
通过部署流分析算法来扩展它们。(需要MATLAB生产服务器)

安装用于MATLAB生产服务器的流数据框架支持包从MATLAB Add-On Explorer。有关安装插件的信息，请参见获取和管理Add-Ons(MATLAB)。

功能

连接到事件流

`kafkaStream`	创建到事件流的连接卡夫卡主题
`inMemoryStream`	创建连接到由。主办的事件流MATLAB不应用模式处理
`testStream`	创建连接到由。主办的事件流MATLAB应用模式处理

读写事件

基本进出口

`readtimetable`	从事件流中阅读时间表
`writetimetable`	将时间表写入事件流
`寻求`	在事件流中设置读取位置
`预览`	从事件流预览事件子集
`identifyingName`	事件流的名字

进出口选项

`detectImportOptions`	根据事件流内容创建导入选项
`eventStreamImportOptions`	创建从流导入事件的选项MATLAB
`ImportOptions`	导入事件流选项
`getvartype`	用于导出变量到流的数据类型
`setvartype`	设置用于导入和导出变量的数据类型为流
`detectExportOptions`	基于事件流内容创建导出选项
`ExportOptions`	导出事件流的选项

卡夫卡流的操作

`readevents`	读取原始事件卡夫卡未应用模式处理的流
`冲洗`	重置读窗口边界
`停止`	停止处理事件流卡夫卡主题
`createTopic`	创建主题卡夫卡集群
`deleteTopic`	从Kafka集群中删除topic
`loggederror`	错误信息为卡夫卡流操作

卡夫卡提供程序属性

`categoryList`	卡夫卡流提供程序属性列表
`getProviderProperties`	卡夫卡流配置属性数据
`型isProperty`	确定卡夫卡设置流提供程序属性

模拟生产环境

`eventStreamProcessor`	将流分析函数应用于事件流
`执行`	在特定数量的事件窗口上执行事件流处理函数
`包`	包流处理功能到可部署的存档配置`EventStreamProcessor`
`寻求`	在事件流中设置位置，开始处理事件
`开始`	开始使用本地测试服务器处理事件流
`startServer`	启动本地测试服务器
`停止`	停止使用本地测试服务器处理事件流
`stopServer`	关闭本地测试服务器

部署流分析

streamingDataCompiler 将流处理功能打包到可部署的存档中

主题

过程事件流

流式数据框架的MATLAB生产服务器基础
使用用于MATLAB生产服务器的流数据框架从事件流平台读取和写入，如Kafka。
使用MATLAB处理Kafka事件
使用流分析函数处理Kafka流中的事件。
连接到安全Kafka集群
在创建流对象时设置Kafka提供程序属性。

测试和部署流分析功能

使用本地测试服务器测试流分析功能
使用的开发版本MATLAB生产服务器在部署到之前测试流分析函数MATLAB生产服务器。
在MATLAB生产服务器中部署流分析函数
打包一个流分析功能并部署到服务器。

故障排除

获取Kafka事件流日志文件

定位事件流日志文件，以帮助调试问题。