Phobos is a microframework and library for kafka based applications, it wraps common behaviors needed by consumers/producers in an easy an convenient API. It uses ruby-kafka as its kafka client and core component.

Phobos DB Checkpoint is a plugin to Phobos and is meant as a drop in replacement to Phobos::Handler

Gathers metrics from Phobos, making it possible for Prometheus server to consume this