diff --git a/ee/backend/pkg/kafka/consumer.go b/ee/backend/pkg/kafka/consumer.go
index e252d7aa3..60b3c5f5d 100644
--- a/ee/backend/pkg/kafka/consumer.go
+++ b/ee/backend/pkg/kafka/consumer.go
@@ -65,10 +65,11 @@ func NewConsumer(
 	}
 
 	return &Consumer{
-		c:              c,
-		messageHandler: messageHandler,
-		commitTicker:   commitTicker,
-		pollTimeout:    200,
+		c:                 c,
+		messageHandler:    messageHandler,
+		commitTicker:      commitTicker,
+		pollTimeout:       200,
+		lastReceivedPrtTs: make(map[int32]int64),
 	}
 }