检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
400 DMS.00400067 The available_zones parameter in the request must be an array that contains only one AZ ID. 请求参数available_zones非法，必须为只包含一个可用区ID的数组。
实例创建成功后，跨VPC访问安全协议无法修改。 SASL PLAIN机制 - 未开启“SASL PLAIN机制”时，使用SCRAM-SHA-512机制对账号密码进行认证。 开启“SASL PLAIN机制”后，同时支持SCRAM-SHA-512机制和PLAIN机制，根据实际情况选择其中任意一种配置连接。
ShowSinkTaskDetailRequest request = new ShowSinkTaskDetailRequest(); request.withTopicInfo(ShowSinkTaskDetailRequest.TopicInfoEnum
##如果Kafka安全协议设置为“SASL_PLAINTEXT”，请注释以下参数。 context.verify_mode = ssl.CERT_REQUIRED ##证书文件，SSL证书参考“收集连接信息”章节获取。如果Kafka安全协议设置为“SASL_PLAINTEXT”，请注释以下参数。 context
kafka.v2.model.*; public class ShowInstanceTopicDetailSolution { public static void main(String[] args) { // The AK and SK used for
000000", "domain_id": "d78cbac1..........", "xdomain_id": "30086000........", "xdomain_type": "", "
mechanism=SCRAM-SHA-512 #SASL认证机制为“PLAIN”时，配置信息如下。 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ username="**********"
5567", "user_name": "laiyh", "kafka_manager_user": "root", "maintain_begin": "22:00:00", "maintain_end": "02:00:00", "storage_space":
mechanism=SCRAM-SHA-512 #SASL认证机制为“PLAIN”时，配置信息如下。 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ username="**********"
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
mechanism=SCRAM-SHA-512 #SASL认证机制为“PLAIN”时，配置信息如下。 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ username="**********"
\src\main\java\com\dms\consumer 消费消息的API。 DmsProducer.java .\src\main\java\com\dms\producer 生产消息的API。 dms.sdk.consumer.properties .\src\main\resources
状态码：200 表3 响应Body参数 参数 参数类型 描述 failed_groups Array of failed_groups objects 删除失败的消费组列表。 total Integer 删除失败的个数 表4 failed_groups 参数 参数类型 描述 group_id
mechanism=SCRAM-SHA-512 #SASL认证机制为“PLAIN”时，配置信息如下。 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ username="**********"
type String 支持rabbitmqInstance、kafkaInstance、rocketmqInstance、tags四种。 rabbitmqInstance表示RabbitMQ实例配额。 kafkaInstance表示Kafka实例配额。 rocketmqInstance表示RocketMQ实例配额。
修改为如下内容。 #SASL认证机制为“PLAIN”时，配置信息如下。 sasl.mechanism=PLAIN sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
mechanism=SCRAM-SHA-512 #SASL认证机制为“PLAIN”时，配置信息如下。 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ username="**********"
tion { "action" : "delete", "allFailure" : "kafka" } 响应消息 响应参数 当参数action为delete，allFailure值为kafka时，响应返回为空表示删除成功。参数说明见表3。 表3 参数说明 参数
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
