blob: 2a0842b1c44d957cbe8418970c81c80a178ebe80 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
|
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/):
|
