The JDBC sink connector pulls messages from Pulsar topics and persists the messages to MySQL or SQlite.

Currently, INSERT, DELETE and UPDATE operations are supported.

​

Configuration

The configuration of the JDBC sink connector has the following properties.

​

Property

​

Example

Before using the JDBC sink connector, you need to create a configuration file through one of the following methods.

• JSON
  {
      "userName": "root",
      "password": "jdbc",
      "jdbcUrl": "jdbc:mysql://127.0.0.1:3306/pulsar_mysql_jdbc_sink",
      "tableName": "pulsar_mysql_jdbc_sink"
  }
  
• YAML
  configs:
      userName: "root"
      password: "jdbc"
      jdbcUrl: "jdbc:mysql://127.0.0.1:3306/pulsar_mysql_jdbc_sink"
      tableName: "pulsar_mysql_jdbc_sink"
  

​

Usage

For more information about how to use a JDBC sink connector, see connect Pulsar to Postgres.