kafka-node asynchronous consumer handler

That's how my consumer is initialised:

const client = new kafka.Client(config.ZK_HOST)
const consumer = new kafka.Consumer(client, [{ topic: config.KAFKA_TOPIC, offset: 0}],
{
    autoCommit: false
})

Now the consumer consumer.on('message', message => applyMessage(message))

The thing is applyMessage talks to the database using knex, the code looks something like:

async function applyMessage(message: kafka.Message) {
    const usersCount = await db('users').count()
    // just assume we ABSOLUTELY need to calculate a number of users,
    // so we need previous state
    await db('users').insert(inferUserFromMessage(message))
}

The code above makes applyMessage to execute in parallel for all the messages in kafka, so in the code above given that there are no users in the database yet, usersCount will ALWAYS be 0 even for the second message from kafka where it should be 1 already since first call to applyMessage inserts a user.

How do I "synchronise" the code in a way that all the applyMessage functions run sequentially?

from kafka-node asynchronous consumer handler