v3.0.1

• Now you're able to set the key of the messages (#25)

v3.0.0

• Updated kafkajs to 2.0.0

v2.1.9

chore(release): 2.1.9

v2.1.1

NPM Audit security fixes

v2.1.0

Added options to pass kafkajs producer and consumer configurations to KafkaPubSub

v2.0.0

Not meddling with supplied event payload. Returning kafkajs KafkaMessage back in the onMessage callback.
Also added more tests and updated jest.

v1.0.0

• Tests
• Changed way to create the pubSub (new KafkaPubSub() -> KafkaPubSub.create()) because of initial async actions
• Added groupIdPrefix as mandatory argument

Pre-tests release

Working in a project of mine, but not with appropriate unit tests