From aa1ff1d976d6c25a0c8bda8dc156342292c956b9 Mon Sep 17 00:00:00 2001 From: Adrian Dobrita Date: Thu, 14 Mar 2024 16:26:29 +0200 Subject: [PATCH] proto message type OutportBlock --- process/firehoseDataProcessor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/process/firehoseDataProcessor.go b/process/firehoseDataProcessor.go index 1ae2b58..6006976 100644 --- a/process/firehoseDataProcessor.go +++ b/process/firehoseDataProcessor.go @@ -21,7 +21,7 @@ const ( initPrefix = "INIT" protocolReaderVersion = "1.0" - protoMessageType = "type.googleapis.com/bstream.pb.sf.bstream.v1.OutportBlock" + protoMessageType = "type.googleapis.com/proto.OutportBlock" ) type dataProcessor struct {