diff --git a/Annotation/Kafka.php b/Annotation/Kafka.php
index 101f149a..dbad039e 100644
--- a/Annotation/Kafka.php
+++ b/Annotation/Kafka.php
@@ -32,6 +32,7 @@ use Snowflake\Snowflake;
      */
     public function execute(array $handler): mixed
     {
+        var_dump($handler);
         if (!($handler[0] instanceof ConsumerInterface)) {
             return false;
         }
diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index ce7a10db..0de2effe 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -106,7 +106,7 @@ class Kafka extends \Snowflake\Process\Process
 
                 $message = swoole_serialize(['action' => 'kafka', 'body' => [$topic, $message]]);
 
-                $server->sendMessage($message, random_int(0, $setting));
+                $server->sendMessage($message, random_int(0, $setting - 1));
             } catch (Throwable $exception) {
                 logger()->addError($exception, 'throwable');
             }