From 0798dcde3724e019eceb77fff1c88f049cb35be0 Mon Sep 17 00:00:00 2001
From: qhd <1766646056@qq.com>
Date: Thu, 29 Jan 2026 14:23:50 +0800
Subject: [PATCH] =?UTF-8?q?=E5=9C=A8NATS=E6=B6=88=E6=81=AF=E5=8F=91?=
 =?UTF-8?q?=E5=B8=83=E5=89=8D=E6=B7=BB=E5=8A=A0=E6=B5=81=E7=BB=84=E5=88=9B?=
 =?UTF-8?q?=E5=BB=BA=E6=A3=80=E6=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 message/nats_msg.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/message/nats_msg.go b/message/nats_msg.go
index 519de96..016917f 100644
--- a/message/nats_msg.go
+++ b/message/nats_msg.go
@@ -79,6 +79,10 @@ func (q *natsMessageClient) publish(ctx context.Context, config interface{}, dat
 	if !ok {
 		return fmt.Errorf("无效的 NATS 配置类型")
 	}
+	err := q.createStreamGroup(ctx, cfg)
+	if err != nil {
+		return err
+	}
 	payload, err := json.Marshal(data)
 	if err != nil {
 		return fmt.Errorf("序列化数据失败: %w", err)