diff --git a/client/pubsub.go b/client/pubsub.go index 95cd0c0..99f287c 100644 --- a/client/pubsub.go +++ b/client/pubsub.go @@ -47,9 +47,10 @@ func (c *GRPCClient) PublishEventfromCustomContent(ctx context.Context, pubsubNa } envelop := &pb.PublishEventRequest{ - PubsubName: pubsubName, - Topic: topicName, - Data: bytes, + PubsubName: pubsubName, + Topic: topicName, + Data: bytes, + DataContentType: "application/json", } _, err = c.protoClient.PublishEvent(c.withAuthToken(ctx), envelop)