diff --git a/Kafka/KafkaClient.php b/Kafka/KafkaClient.php
index 1d6e7ae2..2fae8445 100644
--- a/Kafka/KafkaClient.php
+++ b/Kafka/KafkaClient.php
@@ -29,11 +29,12 @@ class KafkaClient
 	/**
 	 * Producer constructor.
 	 * @param string $topic
+	 * @param string $groupId
+	 * @throws ConfigException
 	 * @throws NotFindClassException
 	 * @throws ReflectionException
-	 * @throws ConfigException
 	 */
-	public function __construct(public string $topic)
+	public function __construct(public string $topic, public string $groupId)
 	{
 		$this->conf = di(Conf::class);
 		$this->topicConf = di(TopicConf::class);
@@ -51,7 +52,7 @@ class KafkaClient
 			throw new ConfigException('Please configure relevant information.');
 		}
 		$kafkaConfig->set('metadata.broker.list', $config['brokers']);
-		$kafkaConfig->set('group.id', $config['groupId']);
+		$kafkaConfig->set('group.id', $this->groupId);
 		$kafkaConfig->setErrorCb(function ($kafka, $err, $reason) {
 			logger()->error(sprintf("Kafka error: %s (reason: %s)", rd_kafka_err2str($err), $reason));
 		});