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!

DeChillOP•4/12/24, 2:10 PM

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...

harisenbon•4/14/24, 11:46 PM

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.

Triggering Worker Functions from external Kafka Topic

Similar Threads

Similar Threads

Similar Threads