fix(backend): added missed argument in kafka consumer

2022-10-25 16:11:56 +02:00 · 2022-10-25 16:11:56 +02:00 · 408bd80ec3
commit 408bd80ec3
parent 51b6414cb6
1 changed files with 1 additions and 0 deletions
--- 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: