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

readevents

从 Kafka 流中读取原始事件，无需应用架构处理

自 R2022b 起

全页折叠

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

    语法

    event = readevents(ks)

    说明

    event = readevents(ks) 返回一个结构体数组，其中包含来自 Kafka® 流 ks 的原始事件。流中的每个事件都会在结果结构体数组中创建一个事件结构体。未对该事件应用任何架构处理。

    示例

    示例

    全部折叠

    假设您有一个在网络地址 kafka.host.com:9092 上运行的 Kafka 服务器，该服务器有一个主题 RecamanSequence。

    创建一个 KafkaStream 对象，用于读取和写入 RecamanSequence 主题。

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

  KafkaStream with properties:

                  Topic: "RecamanSequence"
                  Group: "d89f5726-6abf-461d-a14e-4d40ab84c676"
                  Order: EventTime
                   Host: "kafka.host.com"
                   Port: 9092
      ConnectionTimeout: 30
         RequestTimeout: 61
          ImportOptions: "None"
          ExportOptions: "Source: function eventSchema"
          PublishSchema: "true"
             WindowSize: 50
            KeyVariable: "key"
            KeyEncoding: "utf16"
                KeyType: "text"
           KeyByteOrder: "BigEndian"
           BodyEncoding: "utf8"
             BodyFormat: "JSON"
              ReadLimit: "Size"
    TimestampResolution: "Milliseconds"

    从 RecamanSequence 主题读取 50 个事件，这是默认事件数。

    events = readevents(ks)
    events = 

  50×1 struct array with fields:

    key
    value
    timestamp

    readevents 模块其他操作，直到读取 50 条消息或者在 61 秒内未收到任何消息后超时。为了将阻塞时间严格限制为 61 秒（即使有更多可用消息），请在对 ReadLimit=Time 的调用中指定 kafkaStream。例如，要将超时时间更改为 15 秒，请在对 RequestTimeout=15 对象 KafkaStream 的调用中指定 ks。

    输入参数

    全部折叠

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

    输出参量

    全部折叠

    事件信息，以结构体数组形式返回。数组中的每个结构体都有这些字段。

    事件键存储在 Kafka 中，以字符串数组或整数形式返回。该键标识了事件来源。

    数据类型: single | double | int8 | int16 | int32 | int64 | uint8 | uint16 | uint32 | uint64 | char | string

    事件值，指定为字节数组，其格式和编码由流对象的 BodyFormat 和 BodyEncoding 属性决定。事件值不经过模式处理，并且与存储在 Kafka 中的值完全一样，例如，以 JSON 字符串的形式出现。

    数据类型: string | uint8 | uint16

    Kafka 中的事件发生的时间戳或事件提取的时间戳，指定为日期时间标量。

    数据类型: datetime

    版本历史记录

    在 R2022b 中推出

    另请参阅

    |