主要内容

事件流处理

读和写事件,如卡夫卡®事件

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

  • 读和写事件流从一个事件流媒体平台,如卡夫卡。

  • 模拟生产环境测试流分析算法。(需要MATLAB编译器SDK™)

  • 扩展流分析算法通过部署它们。(需要MATLAB生产服务器)

安装MATLAB生产服务器的流数据框架金宝app从MATLAB附加Explorer支持包。安装插件的信息,请参阅获取和管理插件(MATLAB)。

功能

全部展开

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

基本的进出口

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

导入和导出选项

detectImportOptions 基于事件流创建导入选项内容
eventStreamImportOptions 为事件流导入创建选项MATLAB
ImportOptions 事件流的导入选项
getvartype 数据类型用于出口变量流
setvartype 设置数据类型用于进出口变量流
detectExportOptions 基于事件流创建导出选项内容
ExportOptions 事件流的导出选项
readevents 阅读原始事件卡夫卡流不带模式处理应用
冲洗 重置阅读窗口边界
停止 阻止处理事件流卡夫卡主题
createTopic 创建主题卡夫卡集群
deleteTopic 把话题从卡夫卡集群
loggederror 错误信息为卡夫卡流操作
categoryList 卡夫卡流提供者属性列表
getProviderProperties 卡夫卡配置属性数据流
setProviderProperties 具体设置属性卡夫卡配置
型isProperty 确定卡夫卡流提供者属性设置
eventStreamProcessor 流解析函数应用到事件流
执行 事件流处理函数执行特定数量的事件窗口
包 包流处理函数到部署归档文件进行配置EventStreamProcessor
寻求 设置位置开始处理事件的事件流
开始 开始处理事件流使用本地测试服务器
startServer 启动本地测试服务器
停止 停止使用本地测试服务器处理事件流
stopServer 本地测试服务器关闭
streamingDataCompiler 包流处理函数到部署归档文件

主题

过程事件流

测试和部署流解析函数

故障排除

获得卡夫卡事件流日志文件

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