Why your Kafka consumer lags

const consumer = kafka.consumer({ groupId: "orders" });
await consumer.run({
  eachBatch: async ({ batch, resolveOffset, heartbeat }) => {
    for (const message of batch.messages) {
      await handle(message);
      resolveOffset(message.offset);
      await heartbeat();
    }
  },
});