From 587e420cb067c3190c62f4e1a11f0192f93d5201 Mon Sep 17 00:00:00 2001 From: Maciej Mensfeld Date: Thu, 9 Jan 2025 13:29:53 +0100 Subject: [PATCH] remove debug sleep --- lib/karafka/web/processing/consumer.rb | 1 - 1 file changed, 1 deletion(-) diff --git a/lib/karafka/web/processing/consumer.rb b/lib/karafka/web/processing/consumer.rb index 8818572b..6acd2b42 100644 --- a/lib/karafka/web/processing/consumer.rb +++ b/lib/karafka/web/processing/consumer.rb @@ -13,7 +13,6 @@ class Consumer < Karafka::BaseConsumer # Aggregates consumers state into a single current state representation def consume - sleep(rand + 3) bootstrap! consumers_messages = messages.select { |message| message.payload[:type] == 'consumer' }