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

categoryList

R2026b

Kafka 流提供程序属性列表

自 R2022b 起

全页折叠

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

    语法

    list = categoryList(ks,cat)

    描述

    list = categoryList(ks,cat) 从对象 cat 的类别 ks 中返回所有 Kafka® 流提供程序属性的名称和类别及其各自的值。

    返回的 list 是一个交替结构体和值的元胞数组，形式为 {name_sctruct1,value1,...,name_structN,valueN}，其中：

    • name_struct 是一个具有字段 "category" 和 "name" 的结构体。这些字段分别定义类别名称和属性名称。

    • value 包含前面结构体中命名的属性的值。value 可以是任何类型。

    示例

    示例

    全部折叠

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

    创建一个连接到 Kafka 主机的 KafkaStream 对象，并在对象创建期间指定安全属性。

    ks = kafkaStream("kafka.host.com",9092,"CoolingFan", ...
                    "security.protocol","SSL", ...
                    "ssl.truststore.type","PEM", ...
                    "ssl.truststore.location","kafka-boston.pem");

    获取 "Uncategorized" 类别中的两个 Kafka 提供程序属性的名称、类别和值。

    • 属性 ssl.truststore.location 的值为 "kafka-boston.pem"

    • 属性 ssl.truststore.type 的值为 "PEM"

    list = categoryList(ks,"Uncategorized")
prop1 = list{1}
prop2 = list{3}
    list =

  1×4 cell array

    {1×1 struct}    {["kafka-boston.pem"]}    {1×1 struct}    {["PEM"]}


prop1 = 

  struct with fields:

        name: 'ssl.truststore.location'
    category: 'Uncategorized'


prop2 = 

  struct with fields:

        name: 'ssl.truststore.type'
    category: 'Uncategorized'

    输入参数

    全部折叠

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

    Kafka 流提供程序类别名称，指定为字符串标量、字符向量、字符串数组或字符向量元胞数组。下表显示了 Streaming Data Framework for MATLAB Production Server 支持的类别。属性可以属于多个类别。

    类别描述
    Uncategorized

    包含所有不属于任何其他类别的 Kafka 提供程序属性

    Kafka 属性示例：ssl.truststore.pem

    Consumer

    包含特定于 Kafka 消费者的提供程序属性

    Kafka 属性示例：security.protocol

    ConsumerTopic

    包含特定于阅读主题的提供程序属性

    Producer

    包含特定于 Kafka 生产者的提供程序属性

    Kafka 属性示例：security.protocol

    ProducerTopic

    包含特定于写入 Kafka 主题的提供程序属性

    Kafka 属性示例：max.request.size

    CreateTopic

    包含特定于创建 Kafka 主题的提供程序属性

    Kafka 属性示例：retention.ms

    KafkaConnector

    包含用于与 Kafka Connector 接口交互的提供程序属性。当您在 KafkaStream 对象中将 Order 属性设置为 EventTime 时，readtimetable 使用此接口。

    Kafka 属性示例：sasl.jaas.config

    librdkafka

    包含用于与 Kafka 接口 librdkafka 交互的提供程序属性。在 readtimetable 对象中将 Order 属性设置为 IngestTime 时，KafkaStream 使用此接口。writetimetable 始终使用 librdkafka。

    Kafka 属性示例：sasl.username

    示例: categoryList(ks,["WriteTopic" "CreateTopic"]) 返回 ks 中设置的与创建或编写主题相关的任何提供程序属性。

    数据类型: char | string | cell

    版本历史记录

    在 R2022b 中推出

    另请参阅

    | |

    主题