diff --git a/Kafka/Struct.php b/Kafka/Struct.php
index 9476d943..81020306 100644
--- a/Kafka/Struct.php
+++ b/Kafka/Struct.php
@@ -12,7 +12,7 @@ class Struct
 	public int $offset;
 
 	public Message $message;
-	public string $topic;
+	public ?string $topic;
 
 	public mixed $value;
 	public int $part;