检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考3增加SSL证书配置。 在Kafka客户端的“/bin”目录下，通过以下命令删除消费组。 ./kafka-consumer-groups.sh --bootstrap-server {connection-address}
DeleteConsumerGroupOffsetsRequestBody{ Topics: &listTopicsbody, } response, err := client.DeleteConsumerGroupOffsets(request) if err == nil
CreateDeleteConnectorOrderRequest request = new CreateDeleteConnectorOrderRequest(); ConnectorOrderRequestBody body = new ConnectorOrderRequestBody();
DeleteKafkaMessageRequestBody body = new DeleteKafkaMessageRequestBody(); request.withBody(body); try { DeleteKafkaMessageResponse
实例ID。 group 是 String 消费组ID。 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 偏移量，表示从此偏移量开始查询， offset大于等于0。 limit 否 Integer 当次查询返回的最大Topic个数，默认值为10，取值范围为1~50。
"dim_router" : [ "kafka_instance_id" ] }, { "name" : "kafka_broker", "metrics" : [ "broker_data_size", "broker_messages_in_rate"
消费组ID。 取值范围： 不涉及。 id Integer 参数解释： 对应协调器的broker id。 取值范围： 不涉及。 host String 参数解释： 对应协调器的地址。 取值范围： 不涉及。 port Integer 参数解释： 端口号。 取值范围： 不涉及。 请求示例
表4 members 参数 参数类型 描述 host String 参数解释： 消费组consumer地址。 取值范围： 不涉及。 assignment Array of assignment objects 参数解释： consumer分配到的分区信息。 member_id String
false：不进行重命名Topic。 provenance_header_enabled 否 Boolean 参数解释： 是否添加来源header。（仅源端类型为Kafka时会显示） 取值范围： true：添加来源header。 false：不添加来源header。 consumer_strategy 否 String
partitioner.TimeBasedPartitioner", "value_converter" : "org.apache.kafka.connect.converters.ByteArrayConverter", "key_converter" : "org
response, err := client.ShowKafkaProjectTags(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
for Kafka的所有系统权限。 表1 DMS for Kafka系统权限 系统角色/策略名称 描述 类别 依赖关系 DMS FullAccess 分布式消息服务管理员权限，拥有该权限的用户可以操作所有分布式消息服务的功能。 系统策略 无 DMS UserAccess 分布式消息
request.Body = listGroupCreateReqGroupCreateReq response, err := client.UpdateInstanceGroup(request) if err == nil { fmt.Printf("%+v\n"
在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考3增加SSL证书配置。 在Kafka客户端的“/bin”目录下，通过以下命令删除Topic。 ./kafka-topics.sh --bootstrap-server {connection-address}
response, err := client.ShowKafkaTags(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) }
assignment_strategy String 分区分配策略。 表4 members 参数 参数类型 描述 host String 消费组consumer地址。 member_id String 消费组consumer的ID。 client_id String 客户端ID。 表5 group_message_offsets
groupNameGroupCreateReq:= "test" request.Body = &model.GroupCreateReq{ GroupDesc: &groupDescGroupCreateReq, GroupName: &groupNameGroupCreateReq, }
按“Esc”，然后输入以下命令，按“Enter”，保存并退出“producer.properties”文件。 :wq 修改“consumer.properties”文件： 编辑“consumer.properties”文件。 vim consumer.properties 在键盘上按“i”，然后在“consumer
response, err := client.ShowBackgroundTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
response, err := client.ShowMaintainWindows(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
