检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Commercial use Buying an Instance 2 Consumer group management You can now view the retrieval progress, reset the offset, and delete idle consumer groups on the console. Commercial use Deleting a Consumer Group Resetting the Consumer Offset January 2022 No.
Commercial use Buying an Instance 2 Consumer group management You can now view the retrieval progress, reset the offset, and delete idle consumer groups on the console. Commercial use Deleting a Consumer Group Resetting the Consumer Offset January 2022 No.
None Example Requests DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/management Example Responses None SDK Sample Code The SDK sample code is as follows.
URI DELETE /v2/kafka/{project_id}/instances/{instance_id}/kafka-topic-quota Table 1 Path Parameters Parameter Mandatory Type Description instance_id Yes String Definition: Instance ID. You can call the API for querying all instances to obtain the instance ID.
Check the parameter. 400 DMS.00400064 The action parameter in the request must be delete or restart. The action parameter in the request must be delete or restart. Check the action parameter. 400 DMS.00400065 The instances parameter in the request is empty.
URI DELETE /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota Table 1 Path Parameters Parameter Mandatory Type Description instance_id Yes String Instance ID. project_id Yes String Project ID. For details, see Obtaining a Project ID.
Automatically delete: Messages can be produced and consumed, but 10% of the earliest messages will be deleted to ensure sufficient disk space. This policy is suitable for scenarios where no service interruption can be tolerated. Data may be lost.
Number of consecutive periods: 1 Alarm severity: major Total number of accumulated messages in all consumer groups of the instance Delete idle consumer groups, if any.
If you no longer need the logs, delete the log groups and log streams. Parent Topic: Managing Topics
If you no longer need the logs, delete the log groups and log streams. Related Document Why Does Message Poll Often Fail During Rebalancing? Parent Topic: Managing Consumer Groups
spring.kafka.consumer.enable-auto-commit=true spring.kafka.consumer.auto-commit-interval=100 spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer #======== SASL Configuration (Delete
After disabling mutual SSL authentication, modify the server certificate protocol and delete the client certificate configurations in the consumer.properties and producer.properties files on the client. security.protocol=SASL_SSL ssl.truststore.location=/opt/kafka_2.12-2.7.2/config
If the instance is in the Failed state, delete it and try creating another one. If the instance creation fails again, contact customer service. Instances that fail to be created do not occupy other resources.
You cannot restart, delete, or modify an instance in the Change failed state. Contact customer service. Frozen The instance is frozen. Freezing The status between Running and Frozen. Upgrading The instance is being upgraded. Rolling back The instance is being rolled back.
After an instance is created, disabling SASL does not delete the created user.
Options: time_base: Automatically delete the earliest messages. produce_reject: Stop producing new messages. enable_auto_topic Boolean No Indicates whether to enable automatic topic creation. true: enable false: disable If automatic topic creation is enabled, a topic will be automatically
In this case, delete the current Smart Connect task and create another one. In the Rules area, configure the following parameters.
Action Access Level Resource Type (*: required) Condition Key Alias Dependencies dms:instance:connector Write kafka * g:ResourceTag/<tag-key> g:EnterpriseProjectId - vpc:vpcs:get vpc:vpcs:list vpc:ports:get vpc:ports:create vpc:ports:update vpc:ports:delete vpc:securityGroups:get
Access Level Resource Type (*: required) Condition Key Alias Dependencies dms:instance:create Write kafka * g:RequestTag/<tag-key> g:TagKeys g:EnterpriseProjectId dms:ssl dms:publicIp dms:connector - vpc:vpcs:get vpc:vpcs:list vpc:ports:get vpc:ports:create vpc:ports:update vpc:ports:delete
Why Is a Consumer Group Still on the Monitoring Page After Being Deleted? The monitoring data is reported every minute. The reported data will be displayed on the monitoring page after being sorted. This process takes less than 20 minutes. After deleting a consumer group, you can