Added test, changelog entry

elastic · Jan 31, 2025 · 4b046c1 · 4b046c1
1 parent 70d442e
commit 4b046c1
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc
@@ -25,7 +25,7 @@ https://github.com/elastic/beats/compare/v8.8.1\...main[Check the HEAD diff]
 
 
 *Filebeat*
-
+- Added MaxOpenRequests to kafka output config {pull}42515[42515]
 - Convert netflow input to API v2 and disable event normalisation {pull}37901[37901]
 - Removed deprecated Squid from Beats. See <<migrate-from-deprecated-module>> for migration options. {pull}38037[38037]
 - Removed deprecated Sonicwall from Beats. Use the https://docs.elastic.co/integrations/sonicwall[SonicWall Firewall] Elastic integration instead. {pull}38037[38037]

diff --git a/libbeat/outputs/kafka/config_test.go b/libbeat/outputs/kafka/config_test.go
@@ -65,6 +65,10 @@ func TestConfigAcceptValid(t *testing.T) {
 				"realm":        "ELASTIC",
 			},
 		},
+		"set max requests": mapstr.M{
+			"topic":             "tomato",
+			"max_open_requests": 50,
+		},
 	}
 
 	for name, test := range tests {