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

​

Batch support (PostgreSQL)

When using PostgreSQL with batched writes (for example, setting batchSize > 1), add reWriteBatchedInserts=true to the jdbcUrl so the PostgreSQL JDBC driver rewrites batched inserts for better performance.

• Example: jdbc:postgresql://<host>:5432/<db>?reWriteBatchedInserts=true
• The parameter name is case-sensitive: reWriteBatchedInserts.

For details, see the PostgreSQL JDBC driver documentation: https://jdbc.postgresql.org/documentation/use/#:~:text=reWriteBatchedInserts%20(boolean)%20Default%20false%0AThis%20will

​

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.