lmco / streamflow

StreamFlow™ is a stream processing tool designed to help build and monitor processing workflows.
https://github.com/lmco/streamflow/wiki
Apache License 2.0
253 stars 69 forks source link

FlinkSQL Integration #52

Open Montana opened 1 year ago

Montana commented 1 year ago

This is feasible,

We'd need to create a Kafka table using DDL. To try this run:

docker-compose exec kafka bash -c 'kafka-console-consumer.sh --topic user_behavior --bootstrap-server kafka:9094 --from-beginning --max-messages 10

From there you'll see a boot screen, then finally the dashboard:

image