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,
 	})