Triggering Worker Functions from external Kafka Topic
Hi, I have a external Postgres DB that pushes events via Debezium to a Kafka topic. I would like to react to certain events by triggering a CF Worker.
Is there any way I can trigger worker functions in response to Kafka messages or somehow connect a topic to Cloudflare Queues?
Thanks in advance!
2 Replies
My preferred way would be some way to use Kafka Connect to stream the Data to a Cloudflare Queue but if I try to search anywhere for "Kafka" and "Cloudflare" all results are just about internal usage on the CF backend...
I've been looking at something similar, and because workers don't support TCP (I believe), the only way I've been able to connect to a Kafka instance is if it's using Upstash, as they have a REST API for connecting to the kafka instances.