MATLAB 帮助中心
本页采用了机器翻译。点击此处可查看最新英文版本。
Kafka 流提供程序属性列表
自 R2022b 起
此函数需要 Streaming Data Framework for MATLAB® Production Server™。
list = categoryList(ks,cat)
list = categoryList(ks,cat) 从对象 cat 的类别 ks 中返回所有 Kafka® 流提供程序属性的名称和类别及其各自的值。
list
ks
cat
返回的 list 是一个交替结构体和值的元胞数组,形式为 {name_sctruct1,value1,...,name_structN,valueN},其中:
{name_sctruct1,value1,...,name_structN,valueN}
name_struct 是一个具有字段 "category" 和 "name" 的结构体。这些字段分别定义类别名称和属性名称。
name_struct
"category"
"name"
value 包含前面结构体中命名的属性的值。value 可以是任何类型。
value
示例
全部折叠
假设您有一个在网络地址 kafka.host.com:9092 上运行的 Kafka 服务器,该服务器有一个主题 CoolingFan。
kafka.host.com:9092
CoolingFan
创建一个连接到 Kafka 主机的 KafkaStream 对象,并在对象创建期间指定安全属性。
KafkaStream
ks = kafkaStream("kafka.host.com",9092,"CoolingFan", ... "security.protocol","SSL", ... "ssl.truststore.type","PEM", ... "ssl.truststore.location","kafka-boston.pem");
获取 "Uncategorized" 类别中的两个 Kafka 提供程序属性的名称、类别和值。
"Uncategorized"
属性 ssl.truststore.location 的值为 "kafka-boston.pem"
ssl.truststore.location
"kafka-boston.pem"
属性 ssl.truststore.type 的值为 "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
ssl.truststore.pem
Consumer
包含特定于 Kafka 消费者的提供程序属性
Kafka 属性示例:security.protocol
security.protocol
ConsumerTopic
包含特定于阅读主题的提供程序属性
Producer
包含特定于 Kafka 生产者的提供程序属性
ProducerTopic
包含特定于写入 Kafka 主题的提供程序属性
Kafka 属性示例:max.request.size
max.request.size
CreateTopic
包含特定于创建 Kafka 主题的提供程序属性
Kafka 属性示例:retention.ms
retention.ms
KafkaConnector
包含用于与 Kafka Connector 接口交互的提供程序属性。当您在 KafkaStream 对象中将 Order 属性设置为 EventTime 时,readtimetable 使用此接口。
Order
EventTime
readtimetable
Kafka 属性示例:sasl.jaas.config
sasl.jaas.config
librdkafka
包含用于与 Kafka 接口 librdkafka 交互的提供程序属性。在 readtimetable 对象中将 Order 属性设置为 IngestTime 时,KafkaStream 使用此接口。writetimetable 始终使用 librdkafka。
IngestTime
writetimetable
Kafka 属性示例:sasl.username
sasl.username
示例: categoryList(ks,["WriteTopic" "CreateTopic"]) 返回 ks 中设置的与创建或编写主题相关的任何提供程序属性。
categoryList(ks,["WriteTopic" "CreateTopic"])
数据类型: char | string | cell
char
string
cell
在 R2022b 中推出
getProviderProperties | setProviderProperties | isProperty
getProviderProperties
setProviderProperties
isProperty
You clicked a link that corresponds to this MATLAB command:
Run the command by entering it in the MATLAB Command Window. Web browsers do not support MATLAB commands.
选择网站
选择网站以获取翻译的可用内容,以及查看当地活动和优惠。根据您的位置,我们建议您选择:。
您也可以从以下列表中选择网站:
如何获得最佳网站性能
选择中国网站(中文或英文)以获得最佳网站性能。其他 MathWorks 国家/地区网站并未针对您所在位置的访问进行优化。
美洲
欧洲
亚太
联系您当地的办事处