DATASOURCE::KAFKA::Topics类型用于获取Topic信息列表。
语法
{
"Type": "DATASOURCE::KAFKA::Topics",
"Properties": {
"InstanceId": String,
"Topic": String,
"RefreshOptions": String
}
}
属性
属性名称 | 类型 | 必须 | 允许更新 | 描述 | 约束 |
InstanceId | String | 是 | 是 | Topic所属实例的ID。 | 无 |
Topic | String | 是 | 是 | 获取指定Topic信息的Topic名称。 | 无 |
RefreshOptions | String | 否 | 是 | 当资源栈更新时,数据源资源的刷新策略。 | 有效值:
|
返回值
Fn::GetAtt
Topics:Topic列表。
属性名称 | 类型 | 描述 | 约束 |
Topics | List | Topic列表。 | 无 |
Topic | String | Topic名称。 | 无 |
PartitionNum | Number | Topic的分区数量。 | 无 |
Tags | String | 标签列表。 | 无 |
StatusName | String | 服务状态名称。 | 无 |
InstanceId | String | 实例ID。 | 无 |
Remark | String | 备注。 | 无 |
CompactTopic | String | LocalTopic配置为true时,会配置日志清理策略。 | 无 |
CreateTime | String | 创建时间戳。单位:毫秒。 | 无 |
QuotaData | String | 配额数据。 | 无 |
LocalTopic | String | Topic的存储引擎。 | 无 |
示例
ROSTemplateFormatVersion: '2015-09-01'
Parameters:
InstanceId:
Description:
en: Resource id.
Required: true
Type: String
Topic:
Description:
en: Topic Name.
Required: true
Type: String
Resources:
ExtensionDataSource:
Properties:
InstanceId:
Ref: InstanceId
Topic:
Ref: Topic
Type: DATASOURCE::KAFKA::Topics
Outputs:
Topics:
Description: The list of topics.
Value:
Fn::GetAtt:
- ExtensionDataSource
- Topics
{
"ROSTemplateFormatVersion": "2015-09-01",
"Parameters": {
"InstanceId": {
"Type": "String",
"Description": {
"en": "Resource id."
},
"Required": true
},
"Topic": {
"Type": "String",
"Description": {
"en": "Topic Name."
},
"Required": true
}
},
"Resources": {
"ExtensionDataSource": {
"Type": "DATASOURCE::KAFKA::Topics",
"Properties": {
"InstanceId": {
"Ref": "InstanceId"
},
"Topic": {
"Ref": "Topic"
}
}
}
},
"Outputs": {
"Topics": {
"Description": "The list of topics.",
"Value": {
"Fn::GetAtt": [
"ExtensionDataSource",
"Topics"
]
}
}
}
}