- Release Notes and Announcements
- Product Introduction
- Purchase Guide
- Getting Started
- Operation Guide
- Instance Management
- Creating Instance
- Naming with Consecutive Numeric Suffixes or Designated Pattern String
- Viewing Instance
- Upgrading Instance
- Downgrading Instance Configuration
- Terminating/Returning Instances
- Change from Pay-as-You-Go to Monthly Subscription
- Upgrading Instance Version
- Adding Routing Policy
- Public Network Bandwidth Management
- Connecting to Prometheus
- AZ Migration
- Setting Maintenance Time
- Setting Message Size
- Topic Management
- Consumer Group
- Monitoring and Alarms
- Smart Ops
- Permission Management
- Tag Management
- Querying Message
- Event Center
- Migration to Cloud
- Data Compression
- Instance Management
- CKafka Connector
- Best Practices
- Connector Best Practices
- Connecting Flink to CKafka
- Connecting Schema Registry to CKafka
- Connecting Spark Streaming to CKafka
- Connecting Flume to CKafka
- Connecting Kafka Connect to CKafka
- Connecting Storm to CKafka
- Connecting Logstash to CKafka
- Connecting Filebeat to CKafka
- Multi-AZ Deployment
- Production and Consumption
- Log Access
- Replacing Supportive Route (Old)
- Troubleshooting
- API Documentation
- History
- Introduction
- API Category
- Making API Requests
- DataHub APIs
- ACL APIs
- Topic APIs
- BatchModifyGroupOffsets
- BatchModifyTopicAttributes
- CreateConsumer
- CreateDatahubTopic
- CreatePartition
- CreateTopic
- CreateTopicIpWhiteList
- DeleteTopic
- DeleteTopicIpWhiteList
- DescribeDatahubTopic
- DescribeTopic
- DescribeTopicAttributes
- DescribeTopicDetail
- DescribeTopicProduceConnection
- DescribeTopicSubscribeGroup
- FetchMessageByOffset
- FetchMessageListByOffset
- ModifyDatahubTopic
- ModifyTopicAttributes
- DescribeTopicSyncReplica
- Instance APIs
- Route APIs
- Other APIs
- Data Types
- Error Codes
- SDK Documentation
- General References
- FAQs
- Service Level Agreement (New Version)
- Contact Us
- Glossary
- Release Notes and Announcements
- Product Introduction
- Purchase Guide
- Getting Started
- Operation Guide
- Instance Management
- Creating Instance
- Naming with Consecutive Numeric Suffixes or Designated Pattern String
- Viewing Instance
- Upgrading Instance
- Downgrading Instance Configuration
- Terminating/Returning Instances
- Change from Pay-as-You-Go to Monthly Subscription
- Upgrading Instance Version
- Adding Routing Policy
- Public Network Bandwidth Management
- Connecting to Prometheus
- AZ Migration
- Setting Maintenance Time
- Setting Message Size
- Topic Management
- Consumer Group
- Monitoring and Alarms
- Smart Ops
- Permission Management
- Tag Management
- Querying Message
- Event Center
- Migration to Cloud
- Data Compression
- Instance Management
- CKafka Connector
- Best Practices
- Connector Best Practices
- Connecting Flink to CKafka
- Connecting Schema Registry to CKafka
- Connecting Spark Streaming to CKafka
- Connecting Flume to CKafka
- Connecting Kafka Connect to CKafka
- Connecting Storm to CKafka
- Connecting Logstash to CKafka
- Connecting Filebeat to CKafka
- Multi-AZ Deployment
- Production and Consumption
- Log Access
- Replacing Supportive Route (Old)
- Troubleshooting
- API Documentation
- History
- Introduction
- API Category
- Making API Requests
- DataHub APIs
- ACL APIs
- Topic APIs
- BatchModifyGroupOffsets
- BatchModifyTopicAttributes
- CreateConsumer
- CreateDatahubTopic
- CreatePartition
- CreateTopic
- CreateTopicIpWhiteList
- DeleteTopic
- DeleteTopicIpWhiteList
- DescribeDatahubTopic
- DescribeTopic
- DescribeTopicAttributes
- DescribeTopicDetail
- DescribeTopicProduceConnection
- DescribeTopicSubscribeGroup
- FetchMessageByOffset
- FetchMessageListByOffset
- ModifyDatahubTopic
- ModifyTopicAttributes
- DescribeTopicSyncReplica
- Instance APIs
- Route APIs
- Other APIs
- Data Types
- Error Codes
- SDK Documentation
- General References
- FAQs
- Service Level Agreement (New Version)
- Contact Us
- Glossary
This document describes how to pause, start, restart, reconfigure, copy, and delete a task in the Ckafka console.
Editing a data source
1. Log in to the CKafka console.
2. On the Task List page, page, click the ID of the target task to enter its basic information page.
3. 3. Click Change Data Source in the top-right corner of the Data Source module to modify the data source information. MySQL and TDSQL for MySQL database subscription tasks support adding subscribed tables. When the user checks the table for adding subscription:
If the original task has selected Distribute to Multiple Topics when configuring the data target, after adding a subscribed table, you need to edit the data target and assign the distributed topic to the newly subscribed table.
If the newly subscribed table needs to copy the existing data, you can toggle on Copy Existing Data. You need to set the required information as follows:
Copy Existing Data: Select whether to enable it. This option only applies to the newly added tables. For tables that have already been listened on, the original collection logic will apply.
Database for Signaling Table Storage: Select a database to store the signaling table when enabling Copy Existing Data. Make sure the user configured on the connection management page has permission to create, modify, and delete a signaling table.
Editing a data target
1. Log in to the CKafka console.
2. On the Task List page, page, click the ID of the target task to enter its basic information page.
3. Click Change Data Target in the top-right corner of the Data Target module to modify the data target information.
Pausing a task
On the Task List page, click More > Pause Task in the Operation column of the target task and click OK to pause the task.
Note:
If you find that the data task has already affected the normal use of CKafka, you can pause it.
Starting a task
On the Task List page, click More > Start Task in the Operation column of the target task and click OK to start the task.
Note:
A paused task can be resumed to continue dumping data.
Restarting a task
On the Task List page, click More > Restart Task in the Operation column of the target task and click OK to restart the task.
Note:
Abnormal tasks can be restarted. The previously dumped data and CKafka instance involved will not be affected.</td>
Reconfiguring a task
Task creation failures may be caused by incorrect configurations. In this case, you can manually reconfigure a task.
1. On the Task List page, click More > Reconfigure Task in the Operation column of the target task to enter the Configure Task page.
2. Specify the new task name, edit the data target, and click Submit to reconfigure the task.
Copying a task
When you have a large number of tasks with similar configurations, after creating the first task successfully, you can create more tasks quickly with the task copy feature.
Note:
When creating or copying a task, you are not allowed to create a data task with the same data source and data target.
1. On the Task List page, click More > Copy Task in the Operation column of the target task to enter the Configure Task page.
2. Specify the new task name, edit the data target, and click Submit to reconfigure the task.
Deleting a task
On the Task List page, click Delete in the Operation column of the target task and click OK to delete the task.
Note:
Once the task is deleted, data dumping will be stopped and the task record will be deleted, but the previously dumped data and CKafka instance involved will not be affected.
A task cannot be recovered once deleted. Proceed with caution.
Yes
No
Was this page helpful?