diff --git a/backend/windmill-api/src/kafka_triggers_oss.rs b/backend/windmill-api/src/kafka_triggers_oss.rs new file mode 100644 index 0000000000..85e5a2166c --- /dev/null +++ b/backend/windmill-api/src/kafka_triggers_oss.rs @@ -0,0 +1,13 @@ +use crate::db::DB; +use axum::Router; + +pub fn workspaced_service() -> Router { + crate::kafka_triggers_ee::workspaced_service() +} + +pub fn start_kafka_consumers( + _db: DB, + mut _killpill_rx: tokio::sync::broadcast::Receiver<()>, +) -> () { + crate::kafka_triggers_ee::start_kafka_consumers(_db, _killpill_rx) +}