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

setProviderProperties

设置特定于 Kafka 配置的属性

自 R2022b 起

全页折叠

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

    语法

    setProviderProperties(ks,propname1,propval1,...,propnameN,propvalN)

    说明

    setProviderProperties(ks,propname1,propval1,...,propnameN,propvalN) 设置 Kafka® 流提供程序属性。

    注意

    建议您在使用 kafkaStream 创建 Kafka 流对象时设置 Kafka 提供程序属性。如果您需要在使用 setProviderProperties 创建对象后设置属性，请在对象与流交互之前设置它们，例如在读取或写入数据到 Kafka 主题时。流对象与事件流交互后，设置 Kafka 属性可能没有任何效果。

    示例

    示例

    全部折叠

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

    创建一个连接到 Kafka 主题的事件流对象。

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

    设置特定于 Kafka 的安全属性。

    setProviderProperties(ks, ...
    "security.protocol","SASL_SSL", ...
    "sasl.mechanism","SCRAM-SHA-512");

    或者，您可以在创建对象时设置这些属性。

    ks = kafkaStream("kafka.host.com",9092,"CoolingFan", ...
     "security.protocol","SASL_SSL", ...
     "sasl.mechanism","SCRAM-SHA-512");

    输入参数

    全部折叠

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

    Kafka 提供程序属性的名称，指定为字符串标量或字符向量。

    示例: "security.protocol"

    Kafka 提供程序属性的值，指定为 MATLAB 表达式。表达式必须是字符串或者可以转换为字符串。

    示例: "SASL_SSL"

    详细信息

    全部折叠

    版本历史记录

    在 R2022b 中推出

    另请参阅

    | |

    主题