Topics-Topics文档介绍内容-阿里云

alicloud_mns_topics

topics.Example Usage data"alicloud_mns_topics""topics"{ name_prefix="tf-"} output"first_topic_id"{ value="${data.alicloud_mns_topics.topics.topics.0.id}"} Argument Reference The following arguments are supported:name_...

alicloud_ons_topics

topic_remark"} data"alicloud_ons_topics""topics_ds"{ instance_id=alicloud_ons_topic.default.instance_id name_regex=var.topic output_file="topics.txt"} output"first_topic_name"{ value=data.alicloud_ons_topics.topics_ds....

alicloud_alikafka_topics

This data source provides a list of ALIKAFKA Topics in an Alibaba Cloud account according to the specified filters.->NOTE:Available in 1.56.0+Example Usage data"alicloud_alikafka_topics""topics_ds"{ instance_id="xxx"name_...

DATASOURCE:KAFKA:Topics

DATASOURCE:KAFKA:Topics类型用于获取Topic信息列表。语法 {"Type":"DATASOURCE:KAFKA:Topics","Properties":{"InstanceId":String,"Topic":String } } 属性属性名称类型必须允许更新描述约束 InstanceId String 是是 Topic所属实例...

DATASOURCE:MNS:Topics

Outputs":{"Topics":{"Description":"The list of topics.","Value":{"Fn:GetAtt":["Topics","Topics"]} },"TopicNames":{"Description":"The list of topic names.","Value":{"Fn:GetAtt":["Topics","TopicNames"]} } } } YAML 格式 ...

DATASOURCE:ROCKETMQ:Topics

DATASOURCE:ROCKETMQ:Topics类型用于查询Topic的信息列表。语法 {"Type":"DATASOURCE:ROCKETMQ:Topics","Properties":{"InstanceId":String,"TopicName":String } } 属性属性名称类型必须允许更新描述约束 InstanceId String 否是 ...

alicloud_message_service_topics

This data source provides the Message Notification Service Topics of the current Alibaba Cloud user.->NOTE:Available in v1.188.0+.Example Usage data"alicloud_message_service_topics""ids"{ ids=["example_id"]} output"topic_...

迁移Topic上云

实例的ID 待确认的返回结果示例如下：13:40:08 INFO-Begin to migrate topics:[test]13:40:08 INFO-Total topic number:1 13:40:08 INFO-Will create topic:test,isCompactTopic:false,partition number:1 执行以下命令提交要迁移的Topic。...

权限控制

dhs:$region:$accountid:projects/$projectName/topics/$topicName GetRecords dhs:GetRecords acs:dhs:$region:$accountid:projects/$projectName/topics/$topicName GetCursor dhs:GetRecords acs:dhs:$region:$accountid:projects/$...

Confluent官方文档

https://docs.confluent.io/platform/current/control-center/topics/view.html在Control Center使用Message Browser https://docs.confluent.io/platform/current/control-center/topics/messages.html在Control Center中管理Topics ...

事件接口

函数原型 public boolean listenTopics(List<String>topics,EventHandler handler,EventModelType type)请求参数参数必选类型说明 topics true List 订阅Topic 列表 handler true EventHandler 当收到响应、超时或发生错误时回调 type ...

事件接口

listen topics BigInteger result=sdk.getEventService().listenTopics(topics,handler,VMTypeEnum.EVM,EventModelType.PUSH)/调用 EVM 的合约，将触发两个 topic，一个 call_contract 的事件，一个TEST 的事件 EVMParameter parameters=...

API参考

project/topics/test_topic",sha)Signature=base64.b64encode(h.digest())print("Signature:%s"%Signature)请求头部示例：Authorization值格式：DATAHUB AccessId:Signature POST/projects/test_project/topics/test_topic ...

ListTopic

Name Value API ListTopic RAM授权操作 mns:ListTopic 资源 acs:mns:$region:$accountid:/topics 使用说明如果只需要获取特定的主题列表，在调用接口时指定 x-mns-prefix 参数，服务端将返回主题名称与前缀匹配的主题列表。注意如果本次...

事件接口

listen topics BigInteger result=sdk.getEventService().listenTopics(topics,handler,VMTypeEnum.EVM,EventModelType.PUSH)/调用 EVM 的合约，将触发两个 topic，一个 call_contract 的事件，一个TEST 的事件 EVMParameter parameters=...

授权策略和示例

queues/$queueName/messages ListTopic mns:ListTopic acs:mns:$region:$accountid:/topics CreateTopic mns:CreateTopic acs:mns:$region:$accountid:/topics/$topicName DeleteTopic mns:DeleteTopic acs:mns:$region:$accountid:/...

CreateTopic

Name Value API CreateTopic RAM授权操作 mns:CreateTopic 资源 acs:mns:$region:$accountid:/topics/$topicName 使用限制主题名称是一个不超过255个字符的字符串，必须以字母或数字为首字符，剩余部分可以包含字母、数字和短划线（-）。...

ALIYUN:IOT:RuleAction

MNS:forwards data in the topics that have been processed by the rule engine to Message Service(MNS)for message transmission.FC:forwards data in the topics that have been processed by the rule engine to Function Compute for...

ALIYUN:IOT:ProductTopic

Publish.Devices can publish messages using the topics of this category.ALL:Subscribe and publish.Devices can subscribe to and publish messages to the topics of this category.","AllowedValues":["ALL","PUB","SUB"]},...

Subscribe

Name Value API Subscribe RAM授权操作 mns:Subscribe 资源 acs:mns:$region:$accountid:/topics/$topicName/subscriptions/$subscriptionName 使用说明 Subscription名称是一个不超过255个字符的字符串，必须以字母或者数字为首字符，剩余...

Cluster Linking

kafka-topics-create-topic demo-link-topic-partitions 1-bootstrap-server${SOURCE_ADDRESS}-command-config${CONFLUENT_CONFIG}/source.config 确认topic已经创建成功#list topic kafka-topics-list-bootstrap-server${SOURCE_ADDRESS}-...

Unsubscribe

Name Value API Unsubscribe RAM授权操作 mns:Unsubscribe 资源 acs:mns:$region:$accountid:/topics/$topicName/subscriptions/$subscriptionName 请求消息请求消息由请求行、HTTP头和消息体三部分组成：请求行 DELETE/topics/$TopicName...

DeleteTopic

Name Value API DeleteTopic RAM授权操作 mns:DeleteTopic 资源 acs:mns:$region:$accountid:/topics/$topicName 请求消息请求消息由请求行、HTTP头和消息体三部分组成：请求行 DELETE/topics/$TopicName HTTP/1.1 特有Request Header 无...

Cluster Linking

list topic kafka-topics-list-bootstrap-server${SOURCE_ADDRESS}-command-config${CONFLUENT_CONFIG}/source.config#describe topic kafka-topics-describe-topic demo-link-topic-bootstrap-server${SOURCE_ADDRESS}-command-config${...

Subscribe

Request 请求消息由以下几部分组成：请求行 PUT/topics/$TopicName/subscriptions/$SubscriptionName HTTP/1.1 特有Request Header 无，请参见公共参数。Request Body Request Body为XML格式，XML中包含创建Subscription的属性。参数名称 ...

事件和日志

[90890809c654f11d6e72a28fa60149770a0d11ec6c92319d6ceb2bb0a4ea1a15 1122334455667788991011121314151347181920929293949596979812345678]从以上示例中可以看到，日志输出主要包含 from、to、log_data、topics 属性。具体结构信息，参见 ...

通过开源Kafka命令行工具访问消息引擎

bin/kafka-topics.sh-bootstrap-server消息引擎Kafka地址>-delete-topic名称>可使用查看Topics列表的语句查询是否已成功删除。读写数据写入数据。逐条写入数据。执行以下命令后，逐条将数据写入Kafka Topic中。bin/kafka-console-producer...

限制Kafka服务端运维流量

kafka-configs.sh-bootstrap-server core-1-1:9092-entity-type topics-entity-name<your topic name>-describe Partition Reassign场景限流重要限流速度不能过小，如果限流速度过小，将不能触发实际的reassign复制过程。限流参数不会对...

SetSubscriptionAttributes

Name Value API SetSubscriptionAttributes RAM授权操作 mns:SetSubscriptionAttributes 资源 acs:mns:$region:$accountid:/topics/$topicName/subscriptions/$subscriptionName 请求消息请求消息由请求行、URL参数、HTTP头和消息体四部分...

ListTopics

Topics Array of Topics 事件列表。TopicName String 1234出错事件的名称。ProjectId Long 1234 任务节点所在工作空间的ID。NodeOwner String 952795*任务节点责任人的阿里云UID InstanceId Long 12345 事件关联的实例ID。FixTime Long ...

SetTopicAttributes

Name Value API SetTopicAttributes RAM授权操作 mns:SetTopicAttributes 资源 acs:mns:$region:$accountid:/topics/$topicName 请求消息请求消息由请求行、HTTP头和消息体三部分组成：请求行 PUT/topics/$TopicName?metaoverride=true ...

Connector使用案例

key.converter":"org.apache.kafka.connect.storage.StringConverter","value.converter":"org.apache.kafka.connect.storage.StringConverter","topics":"redis-connect-topic","redis.uri":"redis:/r-xxxxxxxxxxxx.redis.rds.aliyuncs....

查询作业信息

MonitorConf String {"inputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic","consumer.group":"kafka_consumer_group"}],"outputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic"}]} 监控配置，...

数据压缩

设置解压缩topics列表，主要包含设备下行topics*/aiot_device_compress_set_decompr_list(device,decompr_list,sizeof(decompr_list)/sizeof(char*));设置压缩模块回调函数。aiot_device_compress_set_callback(device,demo_update_reply,&...

查询作业列表

MonitorConf String {"inputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic","consumer.group":"kafka_consumer_group"}],"outputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic"}]} 监控配置，...

使用Terraform管理Kafka Topic

data"alicloud_alikafka_topics""topics_ds"{ instance_id="实例名称>"output_file="topics.txt"} output"first_topic_name"{#输出列表中的第一个Topic的名称。请注意，索引[0]在这里表示列表中的第一项。value="${data.alicloud_alikafka_...

GetTopicAttributes

Name Value API GetTopicAttributes RAM授权操作 mns:GetTopicAttributes 资源 acs:mns:$region:$accountid:/topics/$topicName 请求消息请求消息由请求行、HTTP头和消息体三部分组成：请求行 GET/topics/$TopicName HTTP/1.1 特有Request...

Kafka Rebalancer工具介绍

重要参数参数描述 topics 待preferred election的topics。zookeeper Kafka使用的ZooKeeper地址。EMR 5.x系列版本，由于不再直接支持以ZooKeeper地址方式与Kafka集群连接，因此无需使用-zookeeper参数，直接使用-bootstrap-server即可。...

ALIYUN:IOT:Rule

and topicShortNamespecifies the custom name of the topic.Basic communication topics or Thing Specification Language(TSL)-based communication topics.Syntax:${deviceName}/topicShortName.You can replace${deviceName} with the+...

修改作业

clusterId":"C-1234567","topics":"kafka_topic","consumer.group":"kafka_consumer_group"}],"outputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic"}]} 监控配置，仅 SPARK_STREAMING类型作业支持监控配置。...

Topics

新品推荐