All Products
Search
Document Center

Data Transmission Service:Configure parameters if the destination instance of a DTS task is an ApsaraMQ for Kafka instance

Last Updated:Mar 07, 2024

This topic describes how to configure some special parameters and obtain the values of the parameters if the destination instance of a Data Transmission Service (DTS) task is an ApsaraMQ for Kafka instance that is connected over Express Connect, VPN Gateway, or Smart Access Gateway.

Usage notes

If you connect an ApsaraMQ for Kafka instance to DTS by using Express Connect, VPN Gateway, or Smart Access Gateway, data is written to the specified nodes. If your source database is a MySQL database, we recommend that you set the Access Method parameter to Alibaba Cloud Instance for the destination ApsaraMQ for Kafka instance.

Parameters

Parameter

Description

Method to obtain the parameter value

Access Method

The access method of the ApsaraMQ for Kafka instance. Select Express Connect, VPN Gateway, or Smart Access Gateway.

Important

You cannot directly select ApsaraMQ for Kafka as the database type for some DTS tasks. In some cases, an ApsaraMQ for Kafka instance is used as a self-managed Kafka cluster to configure a DTS task.

N/A

Connected VPC

The ID of the virtual private cloud (VPC) to which the ApsaraMQ for Kafka instance belongs.

In the Configuration Information section of the Instance Information tab, view the value of the VPC ID parameter.

IP Address or Domain Name

The IP address of the ApsaraMQ for Kafka instance.

In the Endpoint Information section of the Instance Information tab, view the value of the Domain Name column that corresponds to the Type column whose value is Default Endpoint. Move the pointer over the endpoint and view the value of the IP Address parameter.

Note

Enter one of the IP addresses and the port number of the IP address.

Port Number

The service port number of the ApsaraMQ for Kafka instance. Default value: 9092.

Database Account

The username and password of the account that you want to use to access the destination ApsaraMQ for Kafka instance. The Database Account and Database Password parameters are required if you enable the access control list (ACL) feature for the ApsaraMQ for Kafka instance.

Note

For more information about how to enable the ACL feature, see Grant permissions to SASL users.

On the Manage SASL Users tab, view the value of the Username parameter.

Database Password

On the Manage SASL Users tab, find the database account that you want to manage and click Copy Password.

Kafka Version

  • If the version of your ApsaraMQ for Kafka instance is 0.10.2, select 0.10.

  • If the version of your ApsaraMQ for Kafka instance is 2.6.2 or 2.2.0, select Later Than 1.0.

In the Basic Information section of the Instance Information tab, view the value of the Major Version parameter.

Encryption

  • If the ACL feature is enabled for the ApsaraMQ for Kafka instance and the User Type parameter is set to SCRAM, select SCRAM-SHA-256.

  • In other cases, select Non-encrypted.

On the Manage SASL Users tab, view the value of the User Type parameter.

Note

The Manage SASL Users tab is displayed only if you enable the ACL feature for the ApsaraMQ for Kafka instance.

  • The Parameter column in the table contains the special parameters that you need to configure if the destination instance of a DTS task is an ApsaraMQ for Kafka instance.

  • To obtain the values of the parameters in the table, perform the following steps: Go to the Instances page in the Message Queue for Apache Kafka console. In the top navigation bar, select the region in which the destination instance resides. On the Instances page, find the destination instance for which you want to configure parameters, and click the name of the destination instance to go to the Instance Details page.