Kser

Kser is a bundle of python library whose purpose is to serialize tasks to be executed on Kafka consumers.

_images/kser.png
  1. A message comes from Kafka.
  2. Consumer deserialize message and send it to the “router” witch dispatch the message to the registry.
  3. Registry loads the correct entrypoint based on the message content.
  4. Registry execute the entrypoint with the message data and return a result.
  5. Result is sent back to the router which dispatch it.
  6. Result may be sent back to kafka using the Producer.