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)