Data Streams live messages

[piochelepiotr]

What does this PR do?

The integration reads from a config modified by the agent in this PR and retrieves messages from Kafka. It then logs the messages, for the Datadog UI to pick them up.

Motivation

We are working on a new feature called "Live Messages" for Data Streams, for Kafka.
The feature will enable users to retrieve messages from Kafka on-demand, and send them as logs to Datadog.

Review checklist (to be filled by reviewers)

• Feature or bugfix MUST have appropriate tests (unit, integration, e2e)
• Add the qa/skip-qa label if the PR doesn't need to be tested during QA.
• If you need to backport this PR to another branch, you can add the backport/<branch-name> label to the PR and it will automatically open a backport PR once this one is merged

[codecov]

Codecov Report

Attention: Patch coverage is 72.07792% with 43 lines in your changes missing coverage. Please review.

Project coverage is 88.56%. Comparing base (2df1b1d) to head (28b5bc5).

Additional details and impacted files

Flag	Coverage Δ
activemq	?
hive	?
hivemq	?
hudi	?
ignite	?
jboss_wildfly	?
kafka_consumer	89.38% <72.07%> (-1.67%)	⬇️

Flags with carried forward coverage won't be shown. Click here to find out more.

🚀 New features to boost your workflow:

• ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.
• 📦 JS Bundle Analysis: Save yourself from yourself by tracking and limiting bundle sizes in JS merges.

[gitstevenpham]

We don't need to check for this?