Kafka is now reachable from Minikube with new listeners and ports, and Flink adds native PostgreSQL support with a reorganized shared JDBC driver setup.
Kafka
- Added a new listener:
LISTENER_MINIKUBE:PLAINTEXTso Kafka brokers can now be accessed from Minikube. - Additional ports (
29092–29094) are now open for each broker. Example:- LISTENER_minikube://host.minikube.internal:29092
- Other services (connect or schema registry) can also be accessed via host.minikube.internal on their own ports.
Flink JDBC Connector
- Added support to read/write data to a PostgreSQL database.
- Requires the PostgreSQL JDBC driver to be added to the Flink cluster.
- Previously, the driver JAR was only used for the Hive Metastore. Since it’s now shared by multiple services, its download path has changed.
- 👉 Please re-run setup-env.sh to apply this change.