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

createTopic

在 Kafka 集群中创建主题

自 R2022b 起

全页折叠

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

    语法

    createTopic(ks)
    createTopic(ks,MissingTopic=action)

    说明

    如果 Kafka® 集群权限允许创建，则 createTopic(ks) 会在 Kafka 主机上创建一个主题。KafkaStream 对象 ks 指定要创建的主题以及包含该主题的 Kafka 主机的网络地址。

    示例

    createTopic(ks,MissingTopic=action) 指定是否创建主题 Kafka，或者当主题缺失时失败。如果您正在写入的 Kafka 集群配置为自动创建主题，则指定 action 不起作用。

    示例

    全部折叠

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

    创建一个连接到 Kafka 主机的对象，该对象与名为 CoolingFan 的主题进行交互。

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

    如果在创建对象时 CoolingFan 主题不存在，则可以创建它。您必须拥有必要的权限才能创建主题。

    createTopic(ks)

    输入参数

    全部折叠

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

    如果主题不存在则采取的措施，指定为以下值之一：

    • create - 如果您在 Kafka 主机上拥有所需的权限，则创建新主题。

    • fail - 不创建新主题。

    数据类型: char | string

    版本历史记录

    在 R2022b 中推出

    另请参阅

    | | | |