diff --git a/internal/blockchain/fabric/eventstream.go b/internal/blockchain/fabric/eventstream.go
index f17fe08cf4..9f0aad8e63 100644
--- a/internal/blockchain/fabric/eventstream.go
+++ b/internal/blockchain/fabric/eventstream.go
@@ -118,6 +118,7 @@ func (s *streamManager) createSubscription(name, stream, event string) (*subscri
 			ChaincodeID: s.chaincode,
 			EventFilter: event,
 		},
+		FromBlock: "0",
 	}
 	res, err := s.client.R().
 		SetContext(s.ctx).
diff --git a/internal/blockchain/fabric/fabric_test.go b/internal/blockchain/fabric/fabric_test.go
index 724d032dd2..efe749ed7a 100644
--- a/internal/blockchain/fabric/fabric_test.go
+++ b/internal/blockchain/fabric/fabric_test.go
@@ -132,6 +132,7 @@ func TestInitAllNewStreamsAndWSEvent(t *testing.T) {
 			var body map[string]interface{}
 			json.NewDecoder(req.Body).Decode(&body)
 			assert.Equal(t, "es12345", body["stream"])
+			assert.Equal(t, "0", body["fromBlock"])
 			return httpmock.NewJsonResponderOrPanic(200, subscription{ID: "sub12345"})(req)
 		})