Skip to content

[kafka] add system tests to consumer and producer data streams - #15334

Merged
stefans-elastic merged 11 commits into
elastic:mainfrom
stefans-elastic:kafka-consumer-producer-tests
Sep 19, 2025
Merged

[kafka] add system tests to consumer and producer data streams#15334
stefans-elastic merged 11 commits into
elastic:mainfrom
stefans-elastic:kafka-consumer-producer-tests

Conversation

@stefans-elastic

Copy link
Copy Markdown
Contributor

Proposed commit message

See title

Checklist

  • I have reviewed tips for building integrations and this pull request is aligned with them.
  • I have verified that all data streams collect metrics or logs.
  • I have added an entry to my package's changelog.yml file.
  • I have verified that Kibana version constraints are current according to guidelines.
  • I have verified that any added dashboard complies with Kibana's Dashboard good practices

Author's Checklist

  • [ ]

How to test this PR locally

Related issues

Screenshots

@stefans-elastic
stefans-elastic requested a review from a team as a code owner September 16, 2025 09:04
@stefans-elastic stefans-elastic added enhancement New feature or request Team:Obs-InfraObs Observability Infrastructure Monitoring team [elastic/obs-infraobs-integrations] labels Sep 16, 2025
Comment on lines +2 to +6
- version: "1.23.1"
changes:
- description: Add system tests for consumer and producer data streams.
type: enhancement
link: https://github.com/elastic/integrations/pull/15334

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

why enhancement with patch version update?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

because there is no changes to the functionality

@elastic-vault-github-plugin-prod

elastic-vault-github-plugin-prod Bot commented Sep 17, 2025

Copy link
Copy Markdown
Contributor

🚀 Benchmarks report

To see the full report comment with /test benchmark fullreport

@agithomas

Copy link
Copy Markdown
Contributor

Can you regenerate the sample events for the producer dataset and update it as part of this PR?

@@ -0,0 +1,15 @@
FROM apache/kafka:4.0.0

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@stefans-elastic, The changes look good, but I was just wondering, what if we add the setup script to the parent _dev directory of this integration? That way, we can avoid repeating the script in each data stream, especially since there are quite a few data streams in Kafka that use JMX and share the same setup. Only the data stream–specific details might differ. WDYT?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

hmmm, let me try this

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

it worked (at least locally), thanks for the suggestion!
Lets wait for the CI to complete to see if it works in CI tests

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I've actually reverted the change for raft data stream because when later on when we'll introduce variants for the tests we'll need a different set of variants for raft stream (because it would work only if kafka is run in KRaft mode)

@stefans-elastic

Copy link
Copy Markdown
Contributor Author

Can you regenerate the sample events for the producer dataset and update it as part of this PR?

done

@elasticmachine

Copy link
Copy Markdown

💚 Build Succeeded

History

@agithomas agithomas left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM!

@stefans-elastic
stefans-elastic merged commit 3437ddd into elastic:main Sep 19, 2025
9 checks passed
@elastic-vault-github-plugin-prod

Copy link
Copy Markdown
Contributor

Package kafka - 1.23.1 containing this change is available at https://epr.elastic.co/package/kafka/1.23.1/

tehbooom pushed a commit to tehbooom/integrations that referenced this pull request Nov 19, 2025
…ic#15334)

* [kafka] add system tests to consumer and producer data streams

* update PR link

* producer docker healthcheck

* consumer docker healthcheck

* update producer sample_event.json

* moved docker tests setup from individual data streams to top level kafka _dev dir

* revert raft data stream changes

* fix file name
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

enhancement New feature or request Integration:kafka Kafka Team:Obs-InfraObs Observability Infrastructure Monitoring team [elastic/obs-infraobs-integrations]

6 participants