diff --git a/Kafka/Producer.php b/Kafka/Producer.php
index f7313434..96e5a235 100644
--- a/Kafka/Producer.php
+++ b/Kafka/Producer.php
@@ -59,6 +59,17 @@ class Producer extends Component
 	}
 
 
+	/**
+	 * @param string $groupId
+	 * @return Producer
+	 */
+	public function setGroupId(string $groupId): static
+	{
+		$this->conf->set('group.id', $groupId);
+		return $this;
+	}
+
+
 	/**
 	 * @param $servers
 	 * @return Producer