diff --git a/Annotation/Kafka.php b/Annotation/Kafka.php
new file mode 100644
index 00000000..ccc48fa3
--- /dev/null
+++ b/Annotation/Kafka.php
@@ -0,0 +1,35 @@
+<?php
+
+
+namespace Annotation;
+
+
+/**
+ * Class Kafka
+ * @package Annotation
+ */
+#[\Attribute(\Attribute::TARGET_CLASS)] class Kafka extends Attribute
+{
+
+
+    /**
+     * Kafka constructor.
+     * @param string $topic
+     */
+    public function __construct(public string $topic)
+    {
+
+    }
+
+
+    /**
+     * @param array $handler
+     * @return mixed
+     */
+    public function execute(array $handler): mixed
+    {
+        return parent::execute($handler); // TODO: Change the autogenerated stub
+    }
+
+
+}