From ee76077dea443590959c9f6f085d5e17e6175b0e Mon Sep 17 00:00:00 2001
From: fearlessfei <573088370@qq.com>
Date: Thu, 14 Aug 2025 17:27:23 +0800
Subject: [PATCH] feat: consumer name

---
 kq/queue.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/kq/queue.go b/kq/queue.go
index b7f23ac..fcf5d95 100644
--- a/kq/queue.go
+++ b/kq/queue.go
@@ -180,6 +180,10 @@ func newKafkaQueue(c KqConf, handler ConsumeHandler, options queueOptions) queue
 	return q
 }
 
+func (q *kafkaQueue) Name() string {
+	return q.c.Name
+}
+
 func (q *kafkaQueue) Start() {
 	if q.c.CommitInOrder {
 		go q.commitInOrder()