Are the docs for Pulsar IO outdated? I was able to make the Cassandra sink connector work following the instructions but the JDBC Postgres just won’t actually work, it doesn’t write to Postgres (local or dockerized) as described in the docs.

Can you file an issue on Github, describing the steps you took and the results you saw? Thanks

Will do!

Have you checked the connector logs for errors already? @Alexandre Brilhante

Seems to be related to the schema. Weird because I'm using the same schema as the getting started example.

Yes,

id

allowing

null

values seems to be the issue. How are you setting the schema on the topic? Nevermind, you’re following the docs. Can you try creating the schema like this instead:

{
  "type": "AVRO",
  "schema": "{\"type\":\"record\",\"name\":\"Test\",\"fields\":[{\"name\":\"id\",\"type\":\"int\"},{\"name\":\"name\",\"type\":\"string\"}]}",
  "properties": {}
}