From ea658316a2e8122ce10941ba9a125b0343255259 Mon Sep 17 00:00:00 2001 From: Alexander Zavorotynskiy Date: Fri, 10 Jun 2022 09:45:50 +0200 Subject: [PATCH] fix(backend): fixed panic in kafka consumer --- ee/backend/pkg/kafka/consumer.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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), } }