diff --git a/src/Consumers/Consumer.php b/src/Consumers/Consumer.php
index 711d0cb..eb0828b 100644
--- a/src/Consumers/Consumer.php
+++ b/src/Consumers/Consumer.php
@@ -191,7 +191,7 @@ public function consumedMessagesCount(): int
      */
     private function doConsume(): void
     {
-        $message = $this->consumer->consume(config('kafka.consumer_timeout_ms', 2000));
+        $message = $this->consumer->consume((int) config('kafka.consumer_timeout_ms', 2000));
         $this->handleMessage($message);
     }