Integrate OceanBase Cloud with Apache NiFi

Apache NiFi is an automated dataflow processing platform that enables efficient and reliable data transfer between systems. By reading OceanBase Cloud's Binlog data, you can distribute data to various destinations including file systems, message queues (e.g., Kafka), or HTTP endpoints.

Prerequisites

1. You have registered an OceanBase Cloud account and created the following resources:

   • Created a cluster instance with a tenant in the MySQL compatible mode. For details, see Create a cluster instance and Create a tenant.

   • Created a database and user account. For details, see Create a database and Create an account.

   • Enabled Binlog service for the MySQL-compatible tenant. For details, see Enable the Binlog service.

2. The NiFi server IP has been added to the OceanBase Cloud cluster instance allowlist. For details, see Set allowlist groups.

3. Your environment meets these requirements:

   • Java Development Kit (JDK) 1.8 or later
   • Downloaded Apache NiFi installation package

Step 1: Configure NiFi runtime environment

1. Extract the NiFi installation package to your target directory.

2. Modify the conf/nifi.properties configuration file as follows (using HTTP connection as example):

   # Disable HTTPS and configure HTTP access
   nifi.web.https.host=
   nifi.web.https.port=
   nifi.web.http.host=0.0.0.0
   nifi.web.http.port=<custom_port_number>
   
   # Allow insecure remote connections
   nifi.remote.input.secure=false
   

3. Upload the MySQL driver to your NiFi server.

4. Execute the following commands in the NiFi installation directory. Use bin/nifi.sh stop to stop the service.

   # Start service
   bin/nifi.sh start
   

Step 2: Configure dataflow pipeline

1. Access the NiFi console at http://<nifi_server_ip>:<port>/nifi/ through your browser.

2. Configure CaptureChangeMySQL Processor:

   1. Drag the Processor icon from the top toolbar to the canvas, search for and select CaptureChangeMySQL, then click ADD.

      

   2. Right-click the CaptureChangeMySQL Processor and select Configure. Under the PROPERTIES tab, set these parameters and click APPLY:

      Property	Description
      MySQL Nodes	OceanBase Cloud instance address and port
      MySQL Driver Class Name	JDBC driver class: com.mysql.cj.jdbc.Driver
      MySQL Driver Location	Directory containing the driver JAR file
      Username	Database username you created
      Password	Database user password
      Database/Schema Name Pattern	Database to capture Binlog from (supports regex)
      Table Name Pattern	Tables to capture Binlog from (supports regex)
      Include DDL Events	Set to true to capture DDL changes

      

3. Configure PutFile Processor:

   1. Drag another processor to the canvas, search for and select PutFile, then click ADD.

   2. Right-click the PutFile Processor and select Configure. Under PROPERTIES, set the Directory property where Binlog files will be output. Click APPLY.

      

4. Establish dataflow connection:

   1. On the canvas, click the arrow on CaptureChangeMySQL and connect it to PutFile.

   2. In the Create Connection dialog, click ADD.

   3. Right-click the PutFile Processor and select Configure. Under RELATIONSHIPS, set both failure and success to terminate. Click APPLY.

      

5. Start the dataflow:

   1. Right-click the CaptureChangeMySQL Processor and select Start.

   2. Similarly, right-click the PutFile Processor and select Start.

Step 3: Verify data synchronization

1. Insert test data into your OceanBase Cloud database.

2. Verify files are generated in the PutFile directory.

   

3. Inspect file contents to view the captured SQL statement information.