From 031d22d19568089e7a2a1cd148d8140c1571d33d Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Tue, 17 Jun 2025 11:00:53 +0800
Subject: [PATCH] =?UTF-8?q?kafka=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/server/middleware/kafka/kafka.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/src/server/middleware/kafka/kafka.go b/src/server/middleware/kafka/kafka.go
index 4739fd6b..b4a8fdef 100644
--- a/src/server/middleware/kafka/kafka.go
+++ b/src/server/middleware/kafka/kafka.go
@@ -67,7 +67,6 @@ func SendMsg(key, value []byte) error {
 		return nil
 	}
 	err := KafkaMod.WriteMessages(context.Background(), kafka.Message{
-		Topic: topic,
 		Key:   key,
 		Value: value,
 	})