Valentin Baert
05/19/2022, 11:54 AM@task
to process the message (just logging for this POC).
I have written the steps for my POC here if it might help other people : https://gitlab.com/idkw/prefect-orion-gke-pocAnna Geller
05/19/2022, 11:56 AMValentin Baert
05/19/2022, 12:00 PMAnna Geller
05/19/2022, 12:01 PMValentin Baert
05/19/2022, 12:01 PMKevin Kho
05/19/2022, 1:31 PMValentin Baert
05/19/2022, 1:49 PMprefect_2_kafka_kub_no_deployment.py
which is a long running kafka consumer that starts a flow when receiving a kafka message but does not require a deployment nor an agent. Based on the advices given by Anna. I think it's more suitable to my streaming use-case.Anna Geller
05/19/2022, 1:57 PM