Update comment.

artie-labs · Nov 5, 2024 · 0ed6cae · 0ed6cae
1 parent 4cd1dd7
commit 0ed6cae
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kafkalib/writer.go b/lib/kafkalib/writer.go
@@ -96,7 +96,7 @@ func buildKafkaMessageWrapper(topicPrefix string, rawMessage lib.RawMessage) (Ka
 	}, nil
 }
 
-// KafkaMessageWrapper is a wrapper around a Kafka message. We did this so that we can marshal and unmarshal the message
+// KafkaMessageWrapper is a wrapper around [kafka.Message]. We did this so that we can marshal and unmarshal the message safely with our encoding function
 type KafkaMessageWrapper struct {
 	Topic        string `json:"topic"`
 	MessageKey   []byte `json:"messageKey"`