steveo

Steveo - Kafka Task Framework for Node.js

Steveo is a task management library for Kafka

On a highlevel, it works as below, Steveo has 3 main factory components

          +-----------+                  +-----------+
          |           |                  |           |
          |   TASK    |                  | REGISTRY  |
          |           |                  |           |
          |           |                  |           |
          +-----------+                  +-----------+

                          +-----------+
                          |           |
                          |   RUNNER  |
              SEND  <-----|           |<----- RECEIVE
                          |           |
                          +-----------+

Task

Holds the information about the type of task. It has below methods,

• define
• publish
• subscribe
• events

Registry

Responsible for keeping the inventory of tasks. Whenever a new task is created, an entry will be added in the registry

Runner

Responsible for consuming messages,

• process method initialize group consumers and start to consume the messages. It will then call the subscribe callback set on the task

Example

For more details, see example