README.md in phobos-1.6.1 vs README.md in phobos-1.7.0
- old
+ new
@@ -376,36 +376,39 @@
#### Listener notifications
* `listener.start_handler` is sent when invoking `handler.start(kafka_client)`. It includes the following payload:
* listener_id
* group_id
* topic
+ * handler
* `listener.start` is sent when listener starts. It includes the following payload:
* listener_id
* group_id
* topic
+ * handler
* `listener.process_batch` is sent after process a batch. It includes the following payload:
* listener_id
* group_id
* topic
+ * handler
* batch_size
* partition
* offset_lag
* highwater_mark_offset
- * time_elapsed
* `listener.process_message` is sent after process a message. It includes the following payload:
* listener_id
* group_id
* topic
+ * handler
* key
* partition
* offset
* retry_count
- * time_elapsed
* `listener.retry_handler_error` is sent after waited for `handler#consume` retry. It includes the following payload:
* listener_id
* group_id
* topic
+ * handler
* key
* partition
* offset
* retry_count
* waiting_time
@@ -414,30 +417,43 @@
* backtrace
* `listener.retry_aborted` is sent after waiting for a retry but the listener was stopped before the retry happened. It includes the following payload:
* listener_id
* group_id
* topic
+ * handler
* `listener.stopping` is sent when the listener receives signal to stop
* listener_id
* group_id
* topic
+ * handler
* `listener.stop_handler` is sent after stopping the handler
* listener_id
* group_id
* topic
+ * handler
* `listener.stop` is send after stopping the listener
* listener_id
* group_id
* topic
+ * handler
## <a name="plugins"></a> Plugins
List of gems that enhance Phobos:
* [Phobos DB Checkpoint](https://github.com/klarna/phobos_db_checkpoint) is drop in replacement to Phobos::Handler, extending it with the following features:
* Persists your Kafka events to an active record compatible database
* Ensures that your handler will consume messages only once
* Allows your system to quickly reprocess events in case of failures
+
+* [Phobos Checkpoint UI](https://github.com/klarna/phobos_checkpoint_ui) gives your Phobos DB Checkpoint powered app a web gui with the features below. Maintaining a Kafka consumer app has never been smoother:
+ * Search events and inspect payload
+ * See failures and retry / delete them
+
+* [Phobos Prometheus](https://github.com/phobos/phobos_prometheus) adds prometheus metrics to your phobos consumer.
+ * Measures total messages and batches processed
+ * Measures total duration needed to process each message (and batch)
+ * Adds `/metrics` endpoit to scrape data
## <a name="development"></a> Development
After checking out the repo:
* make sure `docker` is installed and running (for windows and mac this also includes `docker-compose`).