From 328f4c2a25ceb860c6effa2edcd47fd385765029 Mon Sep 17 00:00:00 2001
From: jack-berg <34418638+jack-berg@users.noreply.github.com>
Date: Tue, 5 Oct 2021 10:39:38 -0500
Subject: [PATCH] Add integration test for otlp http/protobuf log exporter
 (#3692)

---
 integration-tests/build.gradle.kts              |  1 +
 .../OtlpExporterIntegrationTest.java            | 17 +++++++++++++++++
 2 files changed, 18 insertions(+)

diff --git a/integration-tests/build.gradle.kts b/integration-tests/build.gradle.kts
index 45a73f2612a..df03f57a632 100644
--- a/integration-tests/build.gradle.kts
+++ b/integration-tests/build.gradle.kts
@@ -15,6 +15,7 @@ dependencies {
   testImplementation(project(":exporters:otlp:logs"))
   testImplementation(project(":exporters:otlp-http:trace"))
   testImplementation(project(":exporters:otlp-http:metrics"))
+  testImplementation(project(":exporters:otlp-http:logs"))
   testImplementation(project(":semconv"))
   testImplementation(project(":proto"))
 
diff --git a/integration-tests/src/test/java/io/opentelemetry/OtlpExporterIntegrationTest.java b/integration-tests/src/test/java/io/opentelemetry/OtlpExporterIntegrationTest.java
index a1beafa8808..4becd699a8b 100644
--- a/integration-tests/src/test/java/io/opentelemetry/OtlpExporterIntegrationTest.java
+++ b/integration-tests/src/test/java/io/opentelemetry/OtlpExporterIntegrationTest.java
@@ -22,6 +22,7 @@
 import io.opentelemetry.api.trace.TraceFlags;
 import io.opentelemetry.api.trace.TraceId;
 import io.opentelemetry.api.trace.TraceState;
+import io.opentelemetry.exporter.otlp.http.logs.OtlpHttpLogExporter;
 import io.opentelemetry.exporter.otlp.http.metrics.OtlpHttpMetricExporter;
 import io.opentelemetry.exporter.otlp.http.trace.OtlpHttpSpanExporter;
 import io.opentelemetry.exporter.otlp.logs.OtlpGrpcLogExporter;
@@ -345,6 +346,22 @@ void testOtlpGrpcLogExport() {
     testLogExporter(otlpGrpcLogExporter);
   }
 
+  @Test
+  void testOtlpHttpLogExport() {
+    LogExporter otlpHttpLogExporter =
+        OtlpHttpLogExporter.builder()
+            .setEndpoint(
+                "http://"
+                    + collector.getHost()
+                    + ":"
+                    + collector.getMappedPort(COLLECTOR_OTLP_HTTP_PORT)
+                    + "/v1/logs")
+            .setCompression("gzip")
+            .build();
+
+    testLogExporter(otlpHttpLogExporter);
+  }
+
   private static void testLogExporter(LogExporter logExporter) {
     LogRecord logRecord =
         LogRecord.builder(