monitor.rb in karafka-2.0.0.alpha1

- old
+ new
@@ -14,34 +14,27 @@
       # List of events that we support in the system and to which a monitor client can hook up
       # @note The non-error once support timestamp benchmarking
       # @note Depending on Karafka extensions and additional engines, this might not be the
       #   complete list of all the events. Please use the #available_events on fully loaded
       #   Karafka system to determine all of the events you can use.
-      #   Last 4 events are from WaterDrop but for convenience we use the same monitor for the
-      #   whole karafka ecosystem
       BASE_EVENTS = %w[
-        params.params.deserialize
-        params.params.deserialize.error
-        connection.listener.before_fetch_loop
-        connection.listener.fetch_loop
-        connection.listener.fetch_loop.error
-        connection.client.fetch_loop.error
-        connection.batch_delegator.call
-        connection.message_delegator.call
-        fetcher.call.error
-        backends.inline.process
-        process.notice_signal
-        consumers.responders.respond_with
-        async_producer.call.error
-        async_producer.call.retry
-        sync_producer.call.error
-        sync_producer.call.retry
-        app.initializing
-        app.initialized
         app.running
         app.stopping
-        app.stopping.error
         app.stopped
+
+        consumer.consume
+        consumer.revoked
+        consumer.shutdown
+
+        process.notice_signal
+
+        connection.listener.before_fetch_loop
+        connection.listener.fetch_loop
+        connection.listener.fetch_loop.received
+
+        statistics.emitted
+
+        error.occurred
       ].freeze
 
       private_constant :BASE_EVENTS
 
       # @return [Karafka::Instrumentation::Monitor] monitor instance for system instrumentation