Skip to main content

JDBC Connector

Sink​

The JDBC Sink Connector is used to pull messages from Pulsar topics and persist the messages to an MySQL or Sqlite. Current support INSERT, DELETE and UPDATE.

Sink Configuration Options​

NameRequiredDefaultDescription
userNamefalse``Username used to connect to the database specified by jdbcUrl.
passwordfalse``Password used to connect to the database specified by jdbcUrl.
jdbcUrltrue``The JDBC url of the database this connector connects to.
tableNametrue``The name of the table this connector writes messages to.
nonKeyfalse``Fields used in update events. A comma-separated list.
keyfalse``Fields used in where condition of update and delete Events. A comma-separated list.
timeoutMsfalse500The jdbc operation timeout in milliseconds.
batchSizefalse200The batch size of updates made to the database.