add kafka_integration_test

elastic · Sep 24, 2024 · 7b1019f · 7b1019f
1 parent f055b75
commit 7b1019f
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/libbeat/outputs/kafka/kafka_integration_test.go b/libbeat/outputs/kafka/kafka_integration_test.go
@@ -240,6 +240,18 @@ func TestKafkaPublish(t *testing.T) {
 				"host": "test-host",
 			}),
 		},
+		{
+			"publish message with zstd compression to test topic",
+			map[string]interface{}{
+				"compression": "zstd",
+				"version":     "2.6.0",
+			},
+			testTopic,
+			randMulti(5, 100, mapstr.M{
+				"host": "test-host",
+				"type": "log",
+			}),
+		},
 	}
 
 	defaultConfig := map[string]interface{}{