Upgrade kafkajs package

[gmrabian]

Description

• Upgrade kafkajs package to major version 2
• Rename unmarshall function for clarity
  • although we could just use this function directly, I think the wrapper at least allows future updates to be easier. I believe when we went from v2 to v3 in aws-sdk we had to remove a configuration parameter on the unmarshaller

Resources:
Release log
Official migration guide

Related ticket(s)

CMDCT-4174

---

How to test

• Perform actions that update the DB
• Check the kafka lambda logs to ensure they update (carts-bigmac-streams-cmdct-4174-postKafkaData)

Notes

I matched functionality from v1. For example: timeouts are now default, but I disabled them in our config to match what we did before enforceRequestTimeout: false

The new functionality allows headers to be arrays, and expects us to check for them. Nowhere in our code do we use .headers so I think we are ok. I verified our lambda logs can process arrays of messages as well.

---

Pre-review checklist

• I have added thorough tests, if necessary
• I have updated relevant documentation, if necessary
• I have performed a self-review of my code
• I have manually tested this PR in the deployed cloud environment

[bangbay-bluetiger]

Verified log changes.

[codeclimate]

Code Climate has analyzed commit 0fde9b8 and detected 0 issues on this pull request.

The test coverage on the diff in this pull request is 100.0% (90% is the threshold).

This pull request will bring the total coverage in the repository to 81.3% (0.0% change).

View more on Code Climate.