检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
partition Integer topic分区数，设置消费的并发数。 retention_time Integer 消息老化时间。 sync_replication Boolean 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效，默认关闭。 sync_message_flush
SASL_SSL功能，此时Topic支持配置ACL权限。在Kafka控制台的“Topic管理”页面，在需要设置用户权限的Topic所在行，单击“设置用户权限”，为用户设置不同的权限。 具体操作请参考设置Topic权限。 父主题： Topic和分区问题
对端Kafka开启SASL_SSL时设置的用户名，或者创建SASL_SSL用户时设置的用户名。（仅源端类型为Kafka且对端Kafka认证方式为“SASL_SSL”时需要填写） password 否 String 对端Kafka开启SASL_SSL时设置的密码，或者创建SASL_SSL用户时设置的密码。（
request := &model.UpdateInstanceConsumerGroupRequest{} request.Engine = "{engine}" request.InstanceId = "{instance_id}" request.Group
build() try: request = ResizeEngineInstanceRequest() request.engine = "{engine}" request.instance_id = "{instance_id}"
Build()) request := &model.UpdateInstanceUserRequest{} request.Engine = "{engine}" request.InstanceId = "{instance_id}" request.UserName =
Build()) request := &model.ShowPartitionEndMessageRequest{} request.InstanceId = "{instance_id}" request.Topic = "{topic}" request.Partition
ResetUserPasswrodRequest request = new ResetUserPasswrodRequest(); request.withInstanceId("{instance_id}"); request.withUserName("{user_name}");
Build()) request := &model.ShowPartitionMessageRequest{} request.InstanceId = "{instance_id}" request.Topic = "{topic}" request.Partition
DeleteBackgroundTaskRequest request = new DeleteBackgroundTaskRequest(); request.withInstanceId("{instance_id}"); request.withTaskId("{task_id}");
PauseConnectorTaskRequest request = new PauseConnectorTaskRequest(); request.withInstanceId("{instance_id}"); request.withTaskId("{task_id}");
ResumeConnectorTaskRequest request = new ResumeConnectorTaskRequest(); request.withInstanceId("{instance_id}"); request.withTaskId("{task_id}");
build() try: request = UpdateInstanceRequest() request.instance_id = "{instance_id}" request.body = UpdateInstanceReq(
RestartConnectorTaskRequest request = new RestartConnectorTaskRequest(); request.withInstanceId("{instance_id}"); request.withTaskId("{task_id}");
try: request = UpdateInstanceAutoCreateTopicRequest() request.instance_id = "{instance_id}" request.body = UpdateI
ineRequest request = new ResetMessageOffsetWithEngineRequest(); request.withInstanceId("{instance_id}"); request.withGroup("{group}");
build() try: request = ResetManagerPasswordRequest() request.instance_id = "{instance_id}" request.body = ResetManagerPasswordReq(
BatchDeleteInstanceTopicRequest request = new BatchDeleteInstanceTopicRequest(); request.withInstanceId("{instance_id}");
BatchDeleteInstanceUsersRequest request = new BatchDeleteInstanceUsersRequest(); request.withInstanceId("{instance_id}");
try: request = CreateMessageDiagnosisTaskRequest() request.instance_id = "{instance_id}" request.body = CreateMes
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
