diff --git a/Annotation/Kafka.php b/Annotation/Kafka.php
index ccc48fa3..eefe45bb 100644
--- a/Annotation/Kafka.php
+++ b/Annotation/Kafka.php
@@ -16,7 +16,7 @@ namespace Annotation;
      * Kafka constructor.
      * @param string $topic
      */
-    public function __construct(public string $topic)
+    public function __construct(public string $topic, public string $groupId)
     {
 
     }