We obtain the correct type during snapshotting, but during stream reading a column of type TIMESTAMP (0) WITH TIME ZONE is handled as timestamp instead of timestamptz (with both, wal2json and decoderbufs).

To reproduce, see "time_table" in postgres_create_tables.ddl and its usage in RecordsStreamProducerIT.shouldReceiveChangesForInsertsWithDifferentDataTypes(). A superfluous schema refresh is triggered there.

Also note that the column "tsp" which is triggering this refresh isn't populated with test data and it's also not part of the assertion. This should be adjusted.