kafka修复

2025-06-17 11:00:53 +08:00 · 2025-06-17 11:00:53 +08:00 · 031d22d195
commit 031d22d195
parent 72b4d08d93
1 changed files with 0 additions and 1 deletions
--- 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,
 	})