This a tiny helper to use with kafka (e.g. for integration tests).
Create a topic with a given kafkajs instance.
// ...
await createTopic(kafka, topic);
// ...
Starts a consumer and waits for the give time for message
// ...
const message = await waitForMessage(kafka, topic, "group-id", 10000);
expect(message).to.be.undefined;