Help Center> ROMA Connect> User Guide> Data Source Management> Connecting to an MRS Kafka Data Source

Connecting to an MRS Kafka Data Source

Overview

ROMA Connect can use MRS Kafka as a data source for data integration tasks. Before using the MRS Kafka data source, you need to connect it to ROMA Connect.

Prerequisites

  • Each connected data source must belong to an integration application. Before connecting a data source, ensure that an integration application is available. Otherwise, create an integration application first.
  • Kerberos authentication has been enabled for the MRS cluster where the MRS Kafka data source is located.

Procedure

  1. Log in to the ROMA Connect console. On the Instances page, click View Console next to a specific instance.
  2. In the navigation pane on the left, choose Data Sources. In the upper right corner of the page, click Access Data Source.
  3. On the Default tab page, select MRS Kafka and click Next.
  4. Configure the data source connection information.
    Table 1 Data source connection information

    Parameter

    Description

    Name

    Enter a data source name. It is recommended that you enter a name based on naming rules to facilitate search.

    Integration Application

    Select the integration application to which the data source belongs.

    Description

    Enter the descriptive information.

    Machine-machine Username

    Enter the machine-machine username for connecting to MRS Kafka.

    Configuration File

    Click Upload File to upload the MRS Kafka configuration file. For details, see Obtaining the MRS Kafka Configuration File.

    Obtaining the MRS Kafka Configuration File

    1. Obtain krb5.conf and user.keytab files.

      Download the user authentication file from MRS Manager by following the procedure described in Downloading a User Authentication File, and decompress the file to obtain the krb5.conf and user.keytab files.

    2. Obtain the fikafka-producer.properties, fikafka-consumer.properties, and hosts files.

      Download the client configuration file from the MRS console by following the procedure described in Updating a Client Configuration File. After the file is decompressed:

      Obtain the fikafka-producer.properties and fikafka-consumer.properties files from xxx_Services_ClientConfig_ConfigFiles > Kafka > config.

      Copy the value of bootstrap.servers in the fikafka-producer.properties file to the fikafka-consumer.properties file.

    3. Generate the MRS Kafka configuration file.

      Save the obtained files to a new directory and compress them into a .zip package. All files are stored in the root directory of the .zip package.

      • The file name contains a maximum of 255 characters, including only letters and digits.
      • The file size cannot exceed 2 MB.

    The connection configuration of the MRS Kafka data source is similar to that of the FI HDFS data source. For details, see Connecting to an FI HDFS Data Source.

  5. Click Create.