jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(backend): fixed panic in kafka consumer

Browse source
This commit is contained in:
Alexander Zavorotynskiy 2022-06-10 09:45:50 +02:00
parent b646ba2a9e
commit ea658316a2
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
ee/backend/pkg/kafka/consumer.go
View file

@ -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),
}
}