ALIYUN:KAFKA:ConsumerGroup
ALIYUN:KAFKA:ConsumerGroup类型用于创建消费组。语法 {"Type":"ALIYUN:KAFKA:...{"Ref":"Remark"} } } },"Outputs":{"ConsumerId":{"Description":"Consumer group ID","Value":{"Fn:GetAtt":["ConsumerGroup","ConsumerId"]} } } }
配置消息灰度
例如原来的Consumer Group为 group1，环境标签为gray，开启消息灰度后，则 group1 会被修改成 group1_gray，如果您使用的是阿里云RocketMQ，请提前创建好 group1。默认使用SQL92的过滤方式，如果您使用的是开源RocketMQ，开源的RocketMQ ...
参数说明
consumeFromWhere 新的Consumer Group启动后，用于确定从何处开始拉取，默认从最新位点拉取。consumeThreadMin 消费线程池最小线程数，默认值：20。consumeThreadMax 消费线程池最大线程数，默认值：20。请与最小线程数保持一致。...
GetConsumerProgress-查询消费组消费状态
查询Consumer Group的消费状态。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action ...
使用Sarama-Kafka-Go实现Kafka消费
nil { log.Panicf("Error creating consumer group client:%v",err)} consumptionIsPaused:=false wg:=sync.WaitGroup{} wg.Add(1)go func(){ defer wg.Done()for {/`Consume`应该在一个无限循环内调用，当服务器端重新平衡时，消费者会话...
作为Input接入
alikafka-pre-cn-zv*-2-vpc.alikafka.aliyuncs.com:9092,alikafka-pre-cn-zv*-3-vpc.alikafka.aliyuncs.com:9092 group_idConsumer Group的名称。logstash_group topics Topic的名称。logstash_test consumer_threads 消费线程数。建议与...
其他SQL语句
CREATE GROUP 创建组。CREATE SERVER 创建外部服务器。CREATE TABLE 创建表，Hologres仅支持PostgreSQL中 CREATE TABLE 语句的部分功能。其中，不支持的功能如下：UNLOGGED TEMP IF NOT EXISTS LIKE CHECK DEFAULT GENERATED UNIQUE ...
协同消费
使用同一个Sub Id的Consummer在同一个Consumer Group中，同一个shard在一个Consumer Group中只会被分配给1个Consumer。场景 现有3个消费者实例A，B，C，Topic共有10个shard 实例A启动，分配10个shard 实例B，C启动，shard分配为4，3，3 将1...
SQL语法
ABORT ALTER AGGREGATE ALTER CONVERSION ALTER DATABASE ALTER DOMAIN ALTER ...CREATE GROUP CREATE INDEX CREATE LIBRARY CREATE OPERATOR CREATE RESOURCE QUEUE CREATE ROLE CREATE RULE CREATE SCHEMA CREATE SEQUENCE CREATE TABLE ...
兼容Kafka
Consumer Group DataHub的消费组就是订阅id，只能同时订阅单个topic，而kafka的group可以同时订阅多个topic，为了更好的兼容kafka的订阅方式，DataHub又提供了group的功能，用户可以在project下创建group并绑定想要订阅的topic，就可以使用...
读写数据
同时用户可以引入datahub-client-library依赖，datahub-client-library是在Java-SDK读写功能的封装，用户可以使用Producer实现均匀写入shard，也可以使用Consumer实现协同消费，（建议使用）读数据 读取数据有两种方式，使用SDK 使用协同...
公共错误码
诊断 400 BIZ_SUBSCRIPTION_CREATE_ERROR%s.Please check and try again later.Consumer Group创建失败。诊断 400 BIZ_SUBSCRIPTION_DELETE_ERROR%s.Please check and try again later.Consumer Group删除失败。诊断 400 BIZ_SUBSCRIPTION_...
alicloud_dts_consumer_channels
consumer_group_id-The ID of the consumer group.consumer_group_name-The name of the consumer group.consumer_group_user_name-The username of the consumer group.consumption_checkpoint-The time point when the client consumed ...
迁移Group上云
实例的地域ID destInstanceId 目标 云消息队列 Kafka 版 实例的ID 待确认的返回结果示例如下：15:29:45 INFO-Will create consumer groups:[XXX,test-consumer-group]执行以下命令提交要迁移的 Group。java-jar kafka-migration-assessment...
CREATE RESOURCE GROUP
AnalyticDB MySQL 数仓版（3.0）集群支持通过 CREATE RESOURCE GROUP 创建资源组，资源组的粒度为计算节点。前提条件 AnalyticDB MySQL 集群需同时满足如下条件：集群为 数仓版（3.0）。集群系列需为弹性模式集群版（新版）。集群规格需为...
CreateRepositoryGroup-创建代码组
URL""pathWithNamespace string 路径（含父路径）codeup-test-org/test-create-group nameWithNamespace string 名称（含父路径）codeup-test-org/test-create-group（斜杠两侧有空格）type string 类型，默认为 Group Group ...
alicloud_dts_consumer_channel
consumer_group_name-(Required,ForceNew)The name of the consumer group.consumer_group_password-(Required)The password of the consumer group account.The length of the consumer_group_password is limited to 8 to 32 characters....
delete_consumer_group
请求语法 aliyunlog log delete_consumer_group-project=<value>-logstore=<value>-consumer_group=[-access-id=][-access-key=][-sts-token=][-region-endpoint=][-client-name=][-jmes-filter=][-format-output=][-decode-output=]请求...
通过消费组消费日志
consumer_group='consumer-group-1' consumer_name1="consumer-group-1-A"consumer_name2="consumer-group-1-B"token=""if not logstore:logstore='consumer_group_test_'+str(time.time()).replace('.','_')assert endpoint and ...
update_consumer_group
请求语法 aliyunlog log update_consumer_group-project=<value>-logstore=<value>-consumer_group=[-timeout=][-in_order=][-access-id=][-access-key=][-sts-token=][-region-endpoint=][-client-name=][-jmes-filter=][-format-output=]...
ConsumerGroupUpdateCheckPoint-更新消费进度
404 ConsumerNotExist consumer not exist in the consumer group.消费组中不存在该消费者。404 ShardNotExist shard not exist.Shard 不存在。500 InternalServerError Specified Server Error Message.内部服务调用错误。更多信息，请...
get_check_point
aliyunlog log get_check_point-project="aliyun-test-project"-logstore="logstore-a"-consumer_group="consumer-group-1"-shard_id=1 返回示例[{"checkpoint":"MTUyNDE1NTM3OTM3MzkwODQ5Ng=","consumer":"consumer-group-1","shard":1,...
ConsumerGroupUpdateCheckPoint
404 ConsumerNotExist consumer not exist in the consumer group.消费组中不存在该消费者。404 ShardNotExist shard not exist.Shard不存在。500 InternalServerError Specified Server Error Message.内部服务调用错误。更多信息，请参见...
alicloud_api_gateway_group
Provides an api group resource.To create an API,you must firstly create a group which is a basic attribute of the API.For information about Api Gateway Group and how to use it,see Create An Api Group->NOTE:Available since ...
CREATE SEQUENCE
Group Sequence 语法 CREATE[GROUP]SEQUENCE[START WITH][UNIT COUNT<numeric value>INDEX]说明 如果未指定类型关键字，在DRDS模式数据库中默认创建Group Sequence。在AUTO模式数据库中创建时需要显式指定GROUP类型。参数说明 参数 说明 ...
update_check_point
请求语法 aliyunlog log update_check_point-project=<value>-logstore=<value>-consumer_group=<value>-shard=<value>-check_point=[-consumer=][-force_success=][-access-id=][-access-key=][-sts-token=][-region-endpoint=][-client-...
ListTagResources-查询资源绑定的标签列表
资源 ID 规则：实例：instanceId Topic：Kafka_alikafka_instanceId_topic Consumer Group：Kafka_alikafka_instanceId_consumerGroup 例如：实例 ID 为 alikafka_post-cn-v0h1fgs2xxxx、Topic 名称为 test-topic、Consumer Group 名称为 ...
list_consumer_group
请求语法 aliyunlog log list_consumer_group-project=<value>-logstore=[-access-id=][-access-key=][-sts-token=][-region-endpoint=][-client-name=][-jmes-filter=][-format-output=][-decode-output=]请求参数 该命令的必选和特有参数...
云上迁移Group
cmd=ConsumerGroupMigrationFromAliyun,request=null,response={"code":200,"requestId":"5AEEFB13-2A6B-4265-97CB-902CFA483339","success":true,"message":"operation success"} 10:54:41 INFO-ConsumerCreate success,consumer group=...
调用HTTP协议的SDK收发普通消息
if e.type="TopicNotExist":print("Topic not exist,please create it.")sys.exit(1)print("Publish Message Fail.Exception:%s"%e)Node.js const { MQClient,MessageProperties }=require('@aliyunmq/mq-http-sdk');设置HTTP接入域名。...
创建表 CREATE TABLE 的不兼容点
本文为您介绍迁移 MySQL 数据库的数据至 OceanBase 数据库 MySQL 租户时，MySQL 数据库执行的 CREATE TABLE DDL 支持被数据传输的 DDL 同步组件转换，但 OceanBase 数据库 MySQL 租户不支持执行的场景。在生成列的基础上再定义生成列 通过 ...
使用Exactly-Once投递语义收发消息
MySQL CREATE TABLE `transaction_record`(`consumer_group` varchar(128)NOT NULL DEFAULT '',`message_id` varchar(255)NOT NULL DEFAULT '',`topic_name` varchar(255)NOT NULL DEFAULT '',`ctime` bigint(20)NOT NULL,`queue_id` int...
Logstash消费
access_id=>process.env.ALIBABA_CLOUD_ACCESS_KEY_ID access_key=>process.env.ALIBABA_CLOUD_ACCESS_KEY_SECRET project=>"your project name"logstore=>"your logstore name"consumer_group=>"consumer group name"consumer_name=>...
logstash-input-sls插件使用说明
input { logservice{ endpoint=>"your project endpoint"access_id=>"your access id"access_key=>"your access key"project=>"your project name"logstore=>"your logstore name"consumer_group=>"consumer group name"consumer_name=>...
Terraform
更多信息，请参见 使用Terraform管理Kafka Consumer Group。alicloud_alikafka_topic 提供Kafka Topic资源。更多信息，请参见 使用Terraform管理Kafka Topic。alicloud_alikafka_sasl_acl 提供Kafka的ACL资源。更多信息，请参见 使用...
TransferRepository-转移代码库
test-org/test-create-codeup nameWithNamespace string 代码库完整名称（含完整组名称）codeup-test-org/test-create-group（斜杠两侧有空格）visibilityLevel integer 可见性 0：私有，仅代码库成员可见 10：企业内公开，企业成员可见 20...
GetCheckPoint
调用GetCheckPoint接口获取指定消费组消费数据时Shard的...404 ConsumerGroupNotExist consumer group not exist.消费组不存在。500 InternalServerError Specified Server Error Message.内部服务调用错误。更多信息，请参见 通用错误码。
ConsumerGroupHeartBeat-消费者发送心跳到服务端
消费者发送心跳到服务端 接口说明 消费者和服务端通过固定...404 ConsumerGroupNotExist consumer group not exist.消费组不存在。500 InternalServerError Specified Server Error Message.内部服务调用错误。更多信息，请参见 通用错误码。
alicloud_edas_deploy_group
app_id-(Required,ForceNew)The ID of the application that you want to deploy.group_name-(Required,ForceNew)The name of the instance group that you want to create.group_type-(ForceNew)The type of the instance group that you ...
ConsumerGroupHeartBeat
调用ConsumerGroupHeartBeat接口为指定消费者发送心跳到...404 ConsumerGroupNotExist consumer group not exist.消费组不存在。500 InternalServerError Specified Server Error Message.内部服务调用错误。更多信息，请参见 通用错误码。
- 产品推荐
- 这些文档可能帮助您