modify

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;
         }

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');
             }