> ## Documentation Index
> Fetch the complete documentation index at: https://planetscale.com/docs/llms.txt
> Use this file to discover all available pages before exploring further.
# Debezium connector for PlanetScale
> The Debezium connector for PlanetScale is a connector for Debezium, an open-source distributed platform for change data capture.
export const PlatformAvailability = ({current, vitess, postgres, neki}) => {
const docsHref = path => {
if (!path) return path;
const normalized = path.startsWith('/') ? path : `/${path}`;
return normalized;
};
const labels = {
vitess: 'Vitess',
postgres: 'Postgres',
neki: 'Neki'
};
const combinedLabels = {
both: 'Vitess and Postgres',
all: 'Vitess, Neki, and Postgres',
'postgres-neki': 'Postgres and Neki'
};
if (combinedLabels[current]) {
return
{combinedLabels[current]}
;
}
const hasVitess = current === 'vitess' || Boolean(vitess);
const hasPostgres = current === 'postgres' || Boolean(postgres);
const hasNeki = current === 'neki' || Boolean(neki);
const only = [hasVitess, hasPostgres, hasNeki].filter(Boolean).length === 1;
const engines = [];
if (current === 'vitess' || current === 'postgres' || current === 'neki') engines.push(current);
if (hasVitess && current !== 'vitess') engines.push('vitess');
if (hasNeki && current !== 'neki') engines.push('neki');
if (hasPostgres && current !== 'postgres') engines.push('postgres');
return
;
};
The [Debezium Connector for PlanetScale](https://github.com/planetscale/debezium-connector-planetscale) is based on the [Debezium Vitess connector](https://debezium.io/documentation/reference/stable/connectors/vitess.html) and packages the PlanetScale-specific connector classes, patches, and runtime dependencies for Kafka Connect and Debezium Server.
This documentation shows you how to set up the Debezium connector for PlanetScale. This will allow you to get Debezium Server running on your machine, connect to PlanetScale, and send messages to a webhook endpoint.
Looking for the 2.x connector? See [Debezium connector for PlanetScale (archived)](/docs/vitess/integrations/debezium-archived).
## Install Java
1. First, you'll need Java 21 installed on your machine. You can find this at [https://www.oracle.com/java/technologies/downloads/](https://www.oracle.com/java/technologies/downloads/).
## Running standalone in Debezium Server
[Debezium Server](https://debezium.io/documentation/reference/stable/operations/debezium-server.html) is a standalone application that can test a Debezium connector end-to-end by hosting the Debezium core as an in-process library and pass data from the source to the sink.
Clone the connector repository:
```bash theme={null}
git clone https://github.com/planetscale/debezium-connector-planetscale.git
cd debezium-connector-planetscale
```
Copy the sample configuration and edit it with your PlanetScale credentials:
```bash theme={null}
cp server/sample-application.properties server/ps.properties
```
Build the project:
```bash theme={null}
./gradlew build
```
Run Debezium Server:
```bash theme={null}
make -C server run
```
### Configure the Debezium connector for PlanetScale
Edit `server/ps.properties` with your configuration.
In this example config, we are going to have the sink send HTTP requests to `webhook.site`.
Go to [`http://webhook.site`](http://webhook.site) to get your own endpoint.
Place the sample config below in `server/ps.properties`, replacing the following placeholders:
* `` with your webhook.site endpoint.
* `` with your PlanetScale database name.
* `` with your PlanetScale connection string hostname.
* `` with your PlanetScale connection string username.
* `` with your PlanetScale connection string password.
```properties theme={null}
debezium.format.value=json
debezium.sink.type=http
debezium.sink.http.url=
debezium.source.schema.history.internal=io.debezium.storage.file.history.FileSchemaHistory
debezium.source.schema.history.internal.file.filename=data/schema_history.dat
debezium.source.offset.storage.file.filename=data/offsets.dat
debezium.source.offset.flush.interval.ms=0
debezium.source.database.hostname=
debezium.source.database.port=443
debezium.source.database.user=
debezium.source.database.password=
debezium.source.vitess.keyspace=
debezium.source.connector.class=com.planetscale.debezium.PlanetscaleConnector
debezium.source.topic.prefix=connector-test
debezium.tasks.max=1
```
## Run it
Once the config is set, you can start it by running `make -C server run`
Any existing rows in any table of `` will show up as events in your `webhook.site` endpoint. Adding/modifying/deleting rows will also show up as events in your endpoint.
## Need help?
Get help from [the PlanetScale Support team](https://planetscale.com/contact?initial=support), or join our [Discord community](https://pscale.link/community) to see how others are using PlanetScale.
This documentation is built and hosted on [Mintlify](https://mintlify.com), a developer documentation platform.