Skip to content

Commit ba59f3c

Browse files
committed
fix pulsar issue
Signed-off-by: Long <long.dai@intel.com>
1 parent b8227f3 commit ba59f3c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pubsub/pulsar/pulsar.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,7 @@ func (p *Pulsar) Publish(req *pubsub.PublishRequest) error {
137137
return nil
138138
}
139139

140-
// parsePublishMetadata parse publish metadata
140+
// parsePublishMetadata parse publish metadata.
141141
func parsePublishMetadata(req *pubsub.PublishRequest) (
142142
msg *pulsar.ProducerMessage, err error) {
143143
msg = &pulsar.ProducerMessage{

0 commit comments

Comments
 (0)