Mark comments

Results 9 comments of


                                            Mark

Commit resolved offsets on group rebalance

According to Kafka Protocol it should submit uncommitted offsets before rejoining. This way it will not double process uncommitted offsets.

When a new consumer is added, the rebalance is completed multiple times triggering the EachMessage function

I solved that by handling batches myself. If on heartbeat I receive rebalance error - I stop fetching, wait to finish the job (make sure that your session interval bigger...

Exception on captureException() call

I use node:18 container. NestJS as a framework. I can't send you code to reproduce as this error I receive if I have any unhandled exception in my app.

Exception on captureException() call

I added this code it try catch where I report exceptions try { const { crypto, msCrypto } = getGlobalObject(); console.log('global.crypto || global.msCrypto', crypto, msCrypto); } catch (e) { console.log('global.crypto...

Exception on captureException() call

Here is result ``` global.crypto || global.msCrypto { getRandomValues: [Function: getRandomValues] } undefined randomUUID func undefined randomUUID crashed TypeError: crypto.randomUUID is not a function at KafkaConsumer.onBatch (/home/node/dist/apps/ethereum-indexer-sushiswap/main.js:1:181174) at async Runner.processEachBatch...