You need to run this each time you change `schema.proto`
```bash
cd resources/experiments/
protoc --java_out=/home/matt/git/opendc/opendc-common/src/main/java/  schema.proto
curl -X DELETE http://localhost:8081/subjects/postgres-topic-value
```
Confluent JDBC sink and source (includes Postgres connector) files: 
https://www.confluent.io/hub/confluentinc/kafka-connect-jdbc

Be aware the project will only work with this OpenDC as there are hidden Maven dependencies.
Kafka topic should be named `postgres_topic`.

Confluent local (see https://www.confluent.io/installation/):