Got it working
Busy writing up the docs. Will share as soon as published
Apache Flink, with Apache iceberg, using a jdbc based catalog, with postgresql for catalog persistence. Object storage using MinIO. And Apache paimon, also using jdbc for catalog.