{"repo":"awto/kafka-workflow","free":true,"listed":false,"github":"https://github.com/awto/kafka-workflow","clone":"git clone https://github.com/awto/kafka-workflow.git","description":"Simple Workflow As Code on Kafka","language":"JavaScript","stars":12,"topics":["kafka","kafka-streams","workflow","workflow-as-code","distributed-systems","microservices-architecture","workflow-management","workflow-management-system","microservice-framework","microservice-orchestration"],"license":"MIT","category":"data-pipelines","readme_excerpt":"Durable JavaScript workflows on Kafka Kafka Workflow is a small workflow-as-code runtime for durable JavaScript and TypeScript workflows on Kafka Streams. Workflow code is normal async code. The difference is that an await can wait for an external event for hours, days, or months while the continuation is serialized into Kafka Streams state. There is no workflow DSL, no heavyweight SDK surface, and no built-in policy engine for things that are better expressed as application protocols. Workflow scripts run on Kafka Streams clusters. The runtime stores workflow continuations in the stream local state store and resumes them from an internal continuation topic, workflow-resume . Kafka supplies the hard distributed-systems pieces: partitioning, recovery, elastic stream processing, and durable logs. The workflow runtime stays small: direct async code, durable refs, output records, workflow threads, and cancellation-aware promise combinators. If Kafka is already part of the platform, workflow execution can reuse the same brokers, topics, Streams deployment model, monitoring, ACLs, retention policy, and operational tooling instead of introducing a separate workflow cluster. Kafka is the implementation substrate here, not the essence of the model. The same approach can run on any stateless stream transformer that consumes a durable log, joins each record with durable per-key state, and writes output records. Kafka Streams is a practical host for that contract because many systems alr","default_branch":null,"files":null,"tree":[],"storefront":"/r/awto","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/awto/kafka-workflow/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}