pablocavalieri

There are not much roles on the DB ``` select count(*) from pg_roles; count ------- 25 (1 row) ``` On another environment the same plugin is throwing `FATAL ERROR: CALL_AND_RETRY_LAST...

Hi @raphaelhamonnais , thanks for the post. I'm using `"partitioner.class": "io.confluent.connect.storage.partitioner.TimeBasedPartitioner"` with `"rotate.interval.ms": "60000"` and "path.format": "'date'=YYYY-MM-dd/'hour'=HH", and in fact 1 minute worth of kafka messages are stored on each...