Adding Kafka version 2.2 (#22328)

* Adding Kafka version 2.2 * Adding CHANGELOG entry
elastic · Nov 2, 2020 · 89f38cd · 89f38cd
1 parent 867702e
commit 89f38cd
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc
@@ -482,6 +482,7 @@ https://github.com/elastic/beats/compare/v7.0.0-alpha2...master[Check the HEAD d
 - Add support for OpenStack SSL metadata APIs in `add_cloud_metadata`. {pull}21590[21590]
 - Add cloud.account.id for GCP into add_cloud_metadata processor. {pull}21776[21776]
 - Add proxy metricset for istio module. {pull}21751[21751]
+- Added Kafka version 2.2 to the list of supported versions. {pull}22328[22328]
 
 *Auditbeat*
 

diff --git a/libbeat/common/kafka/version.go b/libbeat/common/kafka/version.go
@@ -78,6 +78,7 @@ var (
 		"2.0.1": sarama.V2_0_1_0,
 		"2.0":   sarama.V2_0_1_0,
 		"2.1":   sarama.V2_1_0_0,
+		"2.2":   sarama.V2_2_0_0,
 		"2":     sarama.V2_1_0_0,
 	}
 )