Kafka integration test

[robbavey]

What does this PR do?

This PR adds integration tests for the Kafka output, with the use cases, and some of the mechanics around reading events from a kafka topic ported from the beats output.

This PR also includes infrastructure to create a test docker image with Kafka, exposing ports to allow testing over plaintext and SSL.

Checklist

• My code follows the style guidelines of this project
• I have commented my code, particularly in hard-to-understand areas
  - [ ] I have made corresponding changes to the documentation
  - [ ] I have made corresponding change to the default configuration files
• I have added tests that prove my fix is effective or that my feature works
  - [ ] I have added an entry in CHANGELOG.md or CHANGELOG-developer.md.

How to test this PR locally

• Run docker-compose up in the testing/environment/docker folder
• Run mage integrationTest

Note that I needed to delete the docker_kafka container after each test run to allow the tests to continue to run.

Related issues

Relates #166, #176

[mergify]

This pull request does not have a backport label.
If this is a bug or security fix, could you label this PR @robbavey? 🙏.
For such, you'll need to label your PR with:

• The upcoming major version of the Elastic Stack
• The upcoming minor version of the Elastic Stack (if you're not pushing a breaking change)

To fixup this pull request, you need to add the backport labels for the needed
branches, such as:

• backport-v8./d.0 is the label to automatically backport to the 8./d branch. /d is the digit

[elasticmachine]

💚 Build Succeeded

the below badges are clickable and redirect to their specific view in the CI or DOCS

Expand to view the summary

Build stats

• Start Time: 2022-12-20T22:46:44.305+0000

• Duration: 16 min 32 sec

❕ Flaky test report

No test was executed to be analysed.

🤖 GitHub comments

Expand to view the GitHub comments

To re-run your PR in the CI, just comment with:

• /test : Re-trigger the build.

[robbavey]

/test

[faec]

This looks great, thank you. It looks like there will be some followup to make these tests runnable in CI / without manually starting containers, but considering the impending holiday I'm happy to worry about that after the other pending integration tests are merged.

[faec]

Oh, missed this initially, it looks like this file needs to have the home directory stripped out or maybe just be deleted if you were just using it for testing the prototype

[robbavey]

🤦‍♂️ Done

[faec]

One other thing if you have time before merging: can you put this in testing/environments/kafka instead of testing/environment/docker? (My pending ES container is in testing/environments/elasticsearch)

[robbavey]

I've moved the files @faec - ket me know if this structure works for you

[faec]

Looks great, thank you again! Don't worry about waiting on @fearful-symmetry for merge, they are already out for the holiday :-)