An example of Spark Structured Streaming with Kafka Integration.
- Download PostgreSQL JDBC driver from here.
- Copy the jar to directory
lib
. - Set
JDBC_USERNAME
andJDBC_PASSWORD
environment variable for PostgreSQL username and password in.env
file. - Run
bash ./launch.sh isabel/example.py
.
- Add joins (static - stream & stream - stream).