Skip to content

[metricbeat][kafka] change kafka protocol version from 3.6.0 to 2.1.0#45761

Merged
stefans-elastic merged 4 commits intoelastic:mainfrom
stefans-elastic:kafka-protocol-2.1.0
Aug 11, 2025
Merged

[metricbeat][kafka] change kafka protocol version from 3.6.0 to 2.1.0#45761
stefans-elastic merged 4 commits intoelastic:mainfrom
stefans-elastic:kafka-protocol-2.1.0

Conversation

@stefans-elastic
Copy link
Contributor

@stefans-elastic stefans-elastic commented Aug 6, 2025

Proposed commit message

[metricbeat][kafka] change kafka protocol version from 3.6.0 to 2.1.0 to ensure module compatibility with Kafka 2.x

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.next.asciidoc or CHANGELOG-developer.next.asciidoc.

Disruptive User Impact

Author's Checklist

  • [ ]

How to test this PR locally

Related issues

Use cases

Screenshots

Testing was performed with Kafka 2.2.0 and Kafka 3.6.0:
Kafka 2.2.0
metricbeat

Kafka 3.6.0
metricbeat

Also tests were performed with locally built elastic-agent (that included this change):
Kafka 2.2.0
agent_metrics

Kafka 3.6.0
agent_metrics

Logs

@botelastic botelastic bot added the needs_team Indicates that the issue/PR needs a Team:* label label Aug 6, 2025
@github-actions
Copy link
Contributor

github-actions bot commented Aug 6, 2025

🤖 GitHub comments

Expand to view the GitHub comments

Just comment with:

  • run docs-build : Re-trigger the docs validation. (use unformatted text in the comment!)

@mergify
Copy link
Contributor

mergify bot commented Aug 6, 2025

This pull request does not have a backport label.
If this is a bug or security fix, could you label this PR @stefans-elastic? 🙏.
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-8./d is the label to automatically backport to the 8./d branch. /d is the digit
  • backport-active-all is the label that automatically backports to all active branches.
  • backport-active-8 is the label that automatically backports to all active minor branches for the 8 major.
  • backport-active-9 is the label that automatically backports to all active minor branches for the 9 major.
@stefans-elastic stefans-elastic added the Team:Obs-InfraObs Label for the Observability Infrastructure Monitoring team label Aug 7, 2025
@botelastic botelastic bot removed the needs_team Indicates that the issue/PR needs a Team:* label label Aug 7, 2025
@stefans-elastic stefans-elastic marked this pull request as ready for review August 7, 2025 11:51
@stefans-elastic stefans-elastic requested a review from a team as a code owner August 7, 2025 11:51
Copy link
Contributor

@agithomas agithomas left a comment

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 2515ddf into elastic:main Aug 11, 2025
51 checks passed
@stefans-elastic stefans-elastic added the backport-active-all Automated backport with mergify to all the active branches label Aug 13, 2025
@ishleenk17 ishleenk17 added the backport-8.18 Automated backport to the 8.18 branch label Aug 13, 2025
mergify bot pushed a commit that referenced this pull request Aug 13, 2025
…#45761)

* [metricbeat][kafka] change kafka protocol version frpm 3.6.0 to 2.1.0

* update changelog

* add version notes in the code

(cherry picked from commit 2515ddf)
@ishleenk17 ishleenk17 added backport-active-all Automated backport with mergify to all the active branches and removed backport-active-all Automated backport with mergify to all the active branches labels Aug 13, 2025
@stefans-elastic stefans-elastic added backport-active-8 Automated backport with mergify to all the active 8.[0-9]+ branches backport-9.0 Automated backport to the 9.0 branch backport-8.19 Automated backport to the 8.19 branch backport-9.1 Automated backport to the 9.1 branch labels Aug 13, 2025
mergify bot pushed a commit that referenced this pull request Aug 13, 2025
…#45761)

* [metricbeat][kafka] change kafka protocol version frpm 3.6.0 to 2.1.0

* update changelog

* add version notes in the code

(cherry picked from commit 2515ddf)

# Conflicts:
#	metricbeat/module/kafka/consumergroup/consumergroup.go
#	metricbeat/module/kafka/partition/partition.go
mergify bot pushed a commit that referenced this pull request Aug 13, 2025
…#45761)

* [metricbeat][kafka] change kafka protocol version frpm 3.6.0 to 2.1.0

* update changelog

* add version notes in the code

(cherry picked from commit 2515ddf)
mergify bot pushed a commit that referenced this pull request Aug 13, 2025
…#45761)

* [metricbeat][kafka] change kafka protocol version frpm 3.6.0 to 2.1.0

* update changelog

* add version notes in the code

(cherry picked from commit 2515ddf)
stefans-elastic added a commit that referenced this pull request Aug 14, 2025
…sion from 3.6.0 to 2.1.0 (#45970)

* [metricbeat][kafka] change kafka protocol version from 3.6.0 to 2.1.0 (#45761)

* [metricbeat][kafka] change kafka protocol version frpm 3.6.0 to 2.1.0

* update changelog

* add version notes in the code

(cherry picked from commit 2515ddf)

* cleanup CHANGELOG.next.asciidoc

---------

Co-authored-by: stefans-elastic <stefan.stas@elastic.co>
stefans-elastic added a commit that referenced this pull request Aug 14, 2025
…sion from 3.6.0 to 2.1.0 (#45973)

* [metricbeat][kafka] change kafka protocol version from 3.6.0 to 2.1.0 (#45761)

* [metricbeat][kafka] change kafka protocol version frpm 3.6.0 to 2.1.0

* update changelog

* add version notes in the code

(cherry picked from commit 2515ddf)

# Conflicts:
#	metricbeat/module/kafka/consumergroup/consumergroup.go
#	metricbeat/module/kafka/partition/partition.go

* resolve conflicts

---------

Co-authored-by: stefans-elastic <stefan.stas@elastic.co>
stefans-elastic added a commit that referenced this pull request Aug 14, 2025
…ion from 3.6.0 to 2.1.0 (#45974)

* [metricbeat][kafka] change kafka protocol version from 3.6.0 to 2.1.0 (#45761)

* [metricbeat][kafka] change kafka protocol version frpm 3.6.0 to 2.1.0

* update changelog

* add version notes in the code

(cherry picked from commit 2515ddf)

* cleanup CHANGELOG.next.asciidoc

---------

Co-authored-by: stefans-elastic <stefan.stas@elastic.co>
stefans-elastic added a commit that referenced this pull request Aug 14, 2025
…#45761) (#45975)

* [metricbeat][kafka] change kafka protocol version frpm 3.6.0 to 2.1.0

* update changelog

* add version notes in the code

(cherry picked from commit 2515ddf)

Co-authored-by: stefans-elastic <stefan.stas@elastic.co>
@stefans-elastic stefans-elastic mentioned this pull request Oct 8, 2025
6 tasks
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

backport-8.18 Automated backport to the 8.18 branch backport-8.19 Automated backport to the 8.19 branch backport-9.0 Automated backport to the 9.0 branch backport-9.1 Automated backport to the 9.1 branch backport-active-8 Automated backport with mergify to all the active 8.[0-9]+ branches backport-active-all Automated backport with mergify to all the active branches bug Team:Obs-InfraObs Label for the Observability Infrastructure Monitoring team

6 participants