From 408bd80ec3c29ddd4a66cb10aa11f11d90e47be7 Mon Sep 17 00:00:00 2001
From: Alexander Zavorotynskiy <zavorotynskiy@pm.me>
Date: Tue, 25 Oct 2022 16:11:56 +0200
Subject: [PATCH] fix(backend): added missed argument in kafka consumer

---
 ee/backend/pkg/kafka/consumer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/ee/backend/pkg/kafka/consumer.go b/ee/backend/pkg/kafka/consumer.go
index f86912938..b951fcd9c 100644
--- a/ee/backend/pkg/kafka/consumer.go
+++ b/ee/backend/pkg/kafka/consumer.go
@@ -177,6 +177,7 @@ func (consumer *Consumer) ConsumeNext() error {
 				decodeKey(e.Key),
 				*(e.TopicPartition.Topic),
 				uint64(e.TopicPartition.Offset),
+				uint64(e.TopicPartition.Partition),
 				ts))
 		consumer.lastReceivedPrtTs[e.TopicPartition.Partition] = ts
 	case kafka.Error: