本页采用了机器翻译。点击此处可查看英文原文。

stop

停止处理来自 Kafka 主题的事件流

自 R2022b 起

全页折叠

    此函数需要 Streaming Data Framework for MATLAB® Production Server™。

    语法

    stop(ks)

    说明

    stop(ks) 停止处理来自 Kafka® 主题的事件流数据并关闭与该流交互的任何外部进程。

    示例

    示例

    全部折叠

    假设您有一个在网络地址 kafka.host.com:9092 上运行的 Kafka 服务器。该服务器有一个主题 RecamanSequence，其中包含 Recamán 序列中的数字。

    创建一个 KafkaStream 对象，用于从 RecamanSequence 主题读取事件流数据。

    ks = kafkaStream("kafka.host.com",9092,"RecamanSequence");

    从流中读取前 50 行。

    tt = readtimetable(ks)
    tt =

  50×2 timetable

         timestamp          R     key 
    ____________________    __    ____

    27-Jun-2022 18:37:52     0    "0" 
    27-Jun-2022 18:37:53     1    "1" 
    27-Jun-2022 18:37:54     3    "2" 
    27-Jun-2022 18:37:55     6    "3" 
    27-Jun-2022 18:37:56     2    "4" 
    27-Jun-2022 18:37:57     7    "5" 
    27-Jun-2022 18:37:58    13    "6" 
    27-Jun-2022 18:37:59    20    "7" 

             :              :      :  

    27-Jun-2022 18:38:34    37    "42"
    27-Jun-2022 18:38:35    80    "43"
    27-Jun-2022 18:38:36    36    "44"
    27-Jun-2022 18:38:37    81    "45"
    27-Jun-2022 18:38:38    35    "46"
    27-Jun-2022 18:38:39    82    "47"
    27-Jun-2022 18:38:40    34    "48"
    27-Jun-2022 18:38:41    83    "49"

    预览流中的接下来 8 行。读取位置立即设置在从流中读取的最后一行之后。

    preview(ks)
    ans =

  8×2 timetable

         timestamp          R     key 
    ____________________    __    ____

    27-Jun-2022 18:38:42    33    "50"
    27-Jun-2022 18:38:43    84    "51"
    27-Jun-2022 18:38:44    32    "52"
    27-Jun-2022 18:38:45    85    "53"
    27-Jun-2022 18:38:46    31    "54"
    27-Jun-2022 18:38:47    86    "55"
    27-Jun-2022 18:38:48    30    "56"
    27-Jun-2022 18:38:49    87    "57"

    停止处理流。

    stop(ks)

    输入参数

    全部折叠

    连接到 Kafka 流主题的对象，指定为 KafkaStream 对象。

    版本历史记录

    在 R2022b 中推出

    另请参阅

    | | | |

    主题