diff --git a/pkg/log/eth_subscriber.go b/pkg/log/eth_subscriber.go
index b195c0aa38..46eab51996 100644
--- a/pkg/log/eth_subscriber.go
+++ b/pkg/log/eth_subscriber.go
@@ -10,6 +10,7 @@ import (
 	"github.com/ethereum/go-ethereum"
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/core/types"
+	"github.com/ethereum/go-ethereum/rpc"
 
 	"github.com/smartcontractkit/chainlink-common/pkg/logger"
 	"github.com/smartcontractkit/chainlink-common/pkg/services"
@@ -204,6 +205,7 @@ func (sub *ethSubscriber) createSubscription(addresses []common.Address, topics
 
 	utils.RetryWithBackoff(ctx, func() (retry bool) {
 		filterQuery := ethereum.FilterQuery{
+			FromBlock: big.NewInt(rpc.LatestBlockNumber.Int64()),
 			Addresses: addresses,
 			Topics:    [][]common.Hash{topics},
 		}