Project consumes Kafka stream from topic and sinks to postgres database for backup, applies a wiki title url filter and sinks filtered messages to a new topic using Apache Flink.
To run the project you execute the script run.sh in terminal:
./run.sh