Instrument the consumer loop

dasch · dasch · commit 289361ff7745 · 2018-01-25T13:08:05.000+01:00
diff --git a/lib/kafka/consumer.rb b/lib/kafka/consumer.rb
@@ -371,7 +371,9 @@ def consumer_loop
 
       while @running
         begin
-          yield
+          @instrumenter.instrument("loop.consumer") do
+            yield
+          end
         rescue HeartbeatError, OffsetCommitError
           join_group
         rescue RebalanceInProgress
