From 3ac935be64168e2d143d31446528db5822573a64 Mon Sep 17 00:00:00 2001 From: Vijay Nalawade Date: Tue, 22 Dec 2020 23:37:58 -0800 Subject: [PATCH] Fixed message ID format --- pulsar/trigger/subscriber/trigger.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar/trigger/subscriber/trigger.go b/pulsar/trigger/subscriber/trigger.go index 98f3d68..34e3d0d 100644 --- a/pulsar/trigger/subscriber/trigger.go +++ b/pulsar/trigger/subscriber/trigger.go @@ -165,7 +165,7 @@ func (handler *Handler) consume() { } func (handler *Handler) handleMessage(msg pulsar.ConsumerMessage) { - handler.handler.Logger().Debugf("Message received - %s", string(msg.ID().Serialize())) + handler.handler.Logger().Debugf("Message received - %s", msg.ID()) out := &Output{} if handler.handler.Settings()["format"] != nil && handler.handler.Settings()["format"].(string) == "JSON" {