OTLP Source unified endpoint for logs, traces and metrics by ps48 · Pull Request #5677 · opensearch-project/data-prepper

ps48 · 2025-05-04T06:10:54Z

Description

OTLP Source unifies the three existing source OTel-logs,traces and metrics sources. This provides ease of use for a single endpoint for the three sources separated by path. It re-uses most of the existing APIs and services including the latest http-common library for GRPCserver creation.

Major decision points made in the PR:

Port is kept as 21893, logically made sense and 21890/1/2 are taken up by logs, traces and metrics.
The paths are separated out in the config for each type of telemetry and is made optional.
~~3. The codec not configurable to the older format. My argument here is we need to move the new uses to the new OTel format.~~ Updated to the below based on comments
The codec is now configurable defaulting to otel, can be configured to opensearch format if required by the users.

Note: All the above decisions can be changed if, needed.

Adding some sample configuration on usage from README.md here:

otel-telemetry-pipeline:
  source:
    otlp:
      ssl: false
  route:
    - logs: 'getEventType() == "LOG"'
    - traces: 'getEventType() == "TRACE"'
    - metrics: 'getEventType() == "METRIC"'
  sink:
    - pipeline:
        name: "logs-pipeline"
        routes:
          - "logs"
    - pipeline:
        name: "traces-pipeline"
        routes:
          - "traces"
    - pipeline:
        name: "metrics-pipeline"
        routes:
          - "metrics"

Issues Resolved

#5596

Check List

New functionality includes testing.
New functionality has a documentation issue. Please link to it in this PR.
- New functionality has javadoc added
Commits are signed with a real name per the DCO

By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
For more information on following Developer Certificate of Origin and signing off your commits, please check here.

KarstenSchnitter

Hi, thanks for providing this draft. I only added some comments based on a very brief check on the code.

data-prepper-plugins/otlp-source/README.md

KarstenSchnitter · 2025-05-05T09:31:56Z

...ins/otlp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSource.java

+
+      // If the path is null for any of the sources, we will not transform the path
+      // and use the default path
+      if (oTelTraceSourcePath != null && oTelMetricsSourcePath != null && oTelLogsSourcePath != null) {


Why is this check not performed separately on each source path?

Need to check the feasibility of this other approach. Not sure how one service can be of GRPC and other on custom HTTP endpoint.

@KarstenSchnitter This actually made more sense, once I looked into this further. I have changed my approach to accommodate this 😄

...ins/otlp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSource.java

ps48 · 2025-05-06T18:10:32Z

not sure why build is failing here:

> Task :data-prepper-core:integrationTest

PipelinesWithAcksIT > one_pipeline_three_sinks_multiple_records() FAILED
    java.lang.NullPointerException at PipelinesWithAcksIT.java:217

Below is from the local run:

❯ ./gradlew :data-prepper-core:integrationTest

Deprecated Gradle features were used in this build, making it incompatible with Gradle 9.0.

You can use '--warning-mode all' to show the individual deprecation warnings and determine if they come from your own scripts or plugins.

For more on this, please refer to https://docs.gradle.org/8.8/userguide/command_line_interface.html#sec:command_line_warnings in the Gradle documentation.

BUILD SUCCESSFUL in 2m 57s
62 actionable tasks: 1 executed, 61 up-to-date

KarstenSchnitter

Thanks for taking up my suggestion. I would still like to see support for the old "opensearch" format very much.

KarstenSchnitter · 2025-05-06T18:40:11Z

...lugins/http-common/src/main/java/org/opensearch/dataprepper/plugins/server/CreateServer.java

            LOG.warn("Creating http source without SSL/TLS. This is not secure.");
-            LOG.warn("In order to set up TLS for the http source, go here: https://github.com/opensearch-project/data-prepper/tree/main/data-prepper-plugins/http-source#ssl");
+            LOG.warn(
+                    "In order to set up TLS for the http source, go here: https://github.com/opensearch-project/data-prepper/tree/main/data-prepper-plugins/http-source#ssl");


This error message can be misleading. We are in the otel-source not the http source, right?

Please, @Davidding4718 @dlvenable Let me know your thoughts on this as the original authors. I can do a minor PR for this.

Created the PR here: #5689

Approved. Might cause merge conflicts though. Be careful, not to take it out again.

KarstenSchnitter · 2025-05-06T18:43:17Z

...lugins/http-common/src/main/java/org/opensearch/dataprepper/plugins/server/CreateServer.java

 import java.util.function.Function;

-
 public class CreateServer {


I am not so sure about the class name. To me this class looks like a factory of some kind and I would name it as such. But I am also fine with the name it got right now.

Hi Karsten,
The CreateServer abstaction was added in last week by this PR #5653. I can rename it ServerFactory or something similar, but I feel this can be out of scope for this PR.

Yeah, I have seen when the change was introduced. I would appreciate a renaming at some point in time, but I am fine with not doing it in this PR.

agree with Karsten, need better name

KarstenSchnitter · 2025-05-06T18:46:02Z

data-prepper-plugins/otlp-source/README.md

+        username: my-user
+        password: my_s3cr3t
+```
+


Can you add an example with mTLS?

@KarstenSchnitter can you please explain what's needed in the example. I haven't dived deep into the Data prepper and OTel Source auth yet. Is this a feature request or just an example?

Let's say you have a setup were an OTel Collector is used as a local gateway. It is configured to forward data to Data Prepper. To establish trust and proper authentication/authorisation mTLS is used. Would be nice to have this setup at least the Data Prepper part as an example.

data-prepper-plugins/otlp-source/README.md

...ins/otlp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSource.java

ps48 · 2025-05-09T19:31:38Z

Thanks for taking up my suggestion. I would still like to see support for the old "opensearch" format very much.

Added support for Old formats here: 37b71ef

KarstenSchnitter

Thanks for this PR and addressing my comments. Looks good to me now.

KarstenSchnitter · 2025-05-12T14:14:13Z

...lugins/http-common/src/main/java/org/opensearch/dataprepper/plugins/server/CreateServer.java

 import java.util.function.Function;

-
 public class CreateServer {


Yeah, I have seen when the change was introduced. I would appreciate a renaming at some point in time, but I am fine with not doing it in this PR.

KarstenSchnitter · 2025-05-12T14:15:36Z

...lugins/http-common/src/main/java/org/opensearch/dataprepper/plugins/server/CreateServer.java

            LOG.warn("Creating http source without SSL/TLS. This is not secure.");
-            LOG.warn("In order to set up TLS for the http source, go here: https://github.com/opensearch-project/data-prepper/tree/main/data-prepper-plugins/http-source#ssl");
+            LOG.warn(
+                    "In order to set up TLS for the http source, go here: https://github.com/opensearch-project/data-prepper/tree/main/data-prepper-plugins/http-source#ssl");


Approved. Might cause merge conflicts though. Be careful, not to take it out again.

KarstenSchnitter · 2025-05-12T14:18:21Z

data-prepper-plugins/otlp-source/README.md

+        username: my-user
+        password: my_s3cr3t
+```
+


Let's say you have a setup were an OTel Collector is used as a local gateway. It is configured to forward data to Data Prepper. To establish trust and proper authentication/authorisation mTLS is used. Would be nice to have this setup at least the Data Prepper part as an example.

ps48 · 2025-05-30T20:12:10Z

@KarstenSchnitter, will need your approval here again, after resolving the conflicts from main. @dlvenable & @kkondaka will need your help for the second review and approval.
Thanks!

kkondaka · 2025-06-04T20:42:24Z

...lugins/http-common/src/main/java/org/opensearch/dataprepper/plugins/server/CreateServer.java

 import java.util.function.Function;

-
 public class CreateServer {


agree with Karsten, need better name

kkondaka · 2025-06-04T21:22:37Z

...ource/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/ConvertConfiguration.java

+
+import org.opensearch.dataprepper.plugins.server.ServerConfiguration;
+
+public class ConvertConfiguration {


This class name and method name is also little confusing. Do we really need a class for this?

The usage of this class was introduced in this PR: #5653. all other otel source adhere to this. I'd consider changing this as out of scope for this PR as we need to change this for all the Otel sources

kkondaka · 2025-06-04T21:23:40Z

...ins/otlp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSource.java

+          otlpSourceConfig.getTracesOutputFormat() == OTelOutputFormat.OPENSEARCH ? new OTelProtoOpensearchCodec.OTelProtoDecoder() : new OTelProtoStandardCodec.OTelProtoDecoder(),
+          buffer, pluginMetrics);
+
+      ServerConfiguration serverConfiguration = ConvertConfiguration.convertConfiguration(otlpSourceConfig);


Maybe it should just be a private method in this class instead of a separate class.

Same as above. This was introduced in all Otel source with this PR #5653. We can refactor all of them later

kkondaka · 2025-06-04T21:24:52Z

...lp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSourceConfig.java

+  static final String METRICS_PATH = "metrics_path";
+  static final String TRACES_PATH = "traces_path";
+  static final String SSL = "ssl";
+  static final String LOGS_OUTPUT_FORMAT = "logs_output_format";


should we just have one output format?

This looks like a product choice. Form what I thought from Karsten's comment is; some customers might want to use Traces with older opensearch format and logs with OpenSearch format. Hence, kept them separate.

Can we have an output_format to support simple use cases? Then we could also offer the other three for more complicated ones.

yes, updated. Thanks for the input @kkondaka @dlvenable

kkondaka · 2025-06-04T21:25:44Z

...lp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSourceConfig.java

+  @JsonProperty(PORT)
+  private int port = DEFAULT_PORT;
+
+  @JsonProperty(LOGS_PATH)


Same here. Should just take ONE prefix path and append FIXED logs, traces and metrics path to it?

From my understanding these should be kept separate, cause even in the OTLP HTTP exporter they support separate paths for each type of signal. https://github.com/open-telemetry/opentelemetry-collector/tree/v0.87.0/exporter/otlphttpexporter

KarstenSchnitter

Just some minor remarks. But it needs additional review fromother maintainers.

KarstenSchnitter · 2025-06-13T05:28:32Z

data-prepper-plugins/otlp-source/build.gradle

+    testImplementation 'org.junit.jupiter:junit-jupiter-api:5.8.1'
+    testImplementation 'org.mockito:mockito-core:4.0.0'


Shouldn't the versions be inherited from the parent?

Makes sense, I removed them 707889f

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

dlvenable · 2025-06-20T21:59:21Z

...lp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSourceConfig.java

+  static final String METRICS_PATH = "metrics_path";
+  static final String TRACES_PATH = "traces_path";
+  static final String SSL = "ssl";
+  static final String LOGS_OUTPUT_FORMAT = "logs_output_format";


Can we have an output_format to support simple use cases? Then we could also offer the other three for more complicated ones.

...lp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSourceConfig.java

dlvenable · 2025-06-20T22:02:49Z

...lp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSourceConfig.java

+  static final String UNAUTHENTICATED_HEALTH_CHECK = "unauthenticated_health_check";
+
+  @JsonProperty(REQUEST_TIMEOUT)
+  private int requestTimeoutInMillis = DEFAULT_REQUEST_TIMEOUT_MS;


Have this take a Data Prepper Duration instead. This is our new way to handle timeouts.

Here is an example:

data-prepper/data-prepper-plugins/cloudwatch-logs/src/main/java/org/opensearch/dataprepper/plugins/sink/cloudwatch_logs/config/ThresholdConfig.java

Lines 41 to 44 in d76fe17

@JsonProperty("flush_interval")

@DurationMin(seconds = 60)

@DurationMax(seconds = 3600)

private Duration flushInterval = Duration.ofSeconds(DEFAULT_FLUSH_INTERVAL);

...lp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSourceConfig.java

...ins/otlp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSource.java

data-prepper-plugins/otlp-source/data/certificate/test_cert.crt

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

dlvenable

I see you fixed a few comments have resolved those. There are still some about using Duration and also about having a single output_format.

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

ps48 · 2025-06-25T19:02:37Z

@dlvenable Have updated the PR with output_format and Duration changes. Would be great if you can take a look now 😄
Thanks!

dlvenable · 2025-06-25T19:22:38Z

...lp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSourceConfig.java


  public OTelOutputFormat getLogsOutputFormat() {
-    return logsOutputFormat;
+    return logsOutputFormat != OTelOutputFormat.OTEL ? logsOutputFormat : outputFormat;


These should be unit tested.

I did add some unit tests here: https://github.com/opensearch-project/data-prepper/pull/5677/files#diff-214fed7c39c017fb5f1b711bc80d5a88aa02a817c5e23db73e7998d73457ad37R382-R392

I see. Thanks!

Let's improve this code some though:

return logsOutputFormat != null ? logsOutputFormat : outputFormat;

And change the default value of logsOutputFormat to null.

Do the same for the others.

I agree this should be the right way, updated it here: c119aa8

dlvenable · 2025-06-25T20:39:50Z

...lp-source/src/main/java/org/opensearch/dataprepper/plugins/source/otlp/OTLPSourceConfig.java


  public OTelOutputFormat getLogsOutputFormat() {
-    return logsOutputFormat;
+    return logsOutputFormat != OTelOutputFormat.OTEL ? logsOutputFormat : outputFormat;


I see. Thanks!

Let's improve this code some though:

return logsOutputFormat != null ? logsOutputFormat : outputFormat;

And change the default value of logsOutputFormat to null.

Do the same for the others.

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

* init single endpoint Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * add reflection service Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update getmetadata expression to support eventType Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * format files Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update config and add health check Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * add http support and update config options Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * reset Otel trace source Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * add tests for healthcheck, auth, requests and config Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * add tests for grpc Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update retry tests Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update plugin name from otel-telemetry-source to otlp Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update readme with usage details Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * reset Otel trace source changes Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * revert GetMetadataExpressionFunction and OTelTraceSource changes Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * remove example Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update source to use http-common server Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * added back retry tests, use http-common health check Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update readme with authentication details Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * fix checkstyle issues Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * add support for OpenSearch formats & update readme Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * remove dupe in settings Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * remove junit and mockito Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update config fields and move certs Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update tests with new config options Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * use data prepper duration and add generic output_format Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update timeouts to duration Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update the output format defaults to null Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> --------- Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> (cherry picked from commit 5ad289d)

) * init single endpoint * add reflection service * update getmetadata expression to support eventType * format files * update config and add health check * add http support and update config options * reset Otel trace source * add tests for healthcheck, auth, requests and config * add tests for grpc * update retry tests * update plugin name from otel-telemetry-source to otlp * update readme with usage details * reset Otel trace source changes * revert GetMetadataExpressionFunction and OTelTraceSource changes * remove example * update source to use http-common server * added back retry tests, use http-common health check * update readme with authentication details * fix checkstyle issues * add support for OpenSearch formats & update readme * remove dupe in settings * remove junit and mockito * update config fields and move certs * update tests with new config options * use data prepper duration and add generic output_format * update timeouts to duration * update the output format defaults to null --------- (cherry picked from commit 5ad289d) Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> Co-authored-by: Shenoy Pratik <sgguruda@amazon.com>

…-project#5677) * init single endpoint Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * add reflection service Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update getmetadata expression to support eventType Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * format files Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update config and add health check Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * add http support and update config options Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * reset Otel trace source Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * add tests for healthcheck, auth, requests and config Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * add tests for grpc Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update retry tests Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update plugin name from otel-telemetry-source to otlp Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update readme with usage details Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * reset Otel trace source changes Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * revert GetMetadataExpressionFunction and OTelTraceSource changes Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * remove example Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update source to use http-common server Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * added back retry tests, use http-common health check Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update readme with authentication details Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * fix checkstyle issues Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * add support for OpenSearch formats & update readme Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * remove dupe in settings Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * remove junit and mockito Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update config fields and move certs Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update tests with new config options Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * use data prepper duration and add generic output_format Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update timeouts to duration Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> * update the output format defaults to null Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> --------- Signed-off-by: Shenoy Pratik <sgguruda@amazon.com> Signed-off-by: Jonah Calvo <caljonah@amazon.com>

KarstenSchnitter reviewed May 5, 2025

View reviewed changes

ps48 changed the title ~~OTLP Source~~ OTLP Source unified endpoint for logs, traces and metrics May 5, 2025

ps48 marked this pull request as ready for review May 6, 2025 18:18

ps48 requested review from chenqi0805, dinujoh, dlvenable, engechas, graytaylor0, kkondaka, oeyh, san81, sb2k16 and srikanthjg as code owners May 6, 2025 18:18

KarstenSchnitter reviewed May 6, 2025

View reviewed changes

ps48 mentioned this pull request May 7, 2025

Add getEventType() expression function #5686

Merged

7 tasks

ps48 force-pushed the otel-telemetry-source branch from c540ae3 to c0c721d Compare May 8, 2025 19:25

ps48 mentioned this pull request May 9, 2025

Fix log warnings for HTTP server with source name #5689

Merged

4 tasks

KarstenSchnitter previously approved these changes May 12, 2025

View reviewed changes

ps48 dismissed KarstenSchnitter’s stale review via 8400825 May 13, 2025 20:18

ps48 force-pushed the otel-telemetry-source branch from 37b71ef to 8400825 Compare May 13, 2025 20:18

kkondaka reviewed Jun 4, 2025

View reviewed changes

KarstenSchnitter reviewed Jun 13, 2025

View reviewed changes

ps48 added 5 commits June 19, 2025 11:41

init single endpoint

8bd9b4e

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

add reflection service

b73fca4

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

update getmetadata expression to support eventType

f209bff

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

format files

48db7af

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

update config and add health check

2b0f4cd

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

ps48 added 6 commits June 19, 2025 11:42

remove example

725fc2a

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

update source to use http-common server

763b0f2

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

added back retry tests, use http-common health check

865dbd4

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

update readme with authentication details

886f279

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

fix checkstyle issues

91ffa90

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

add support for OpenSearch formats & update readme

1b75321

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

ps48 force-pushed the otel-telemetry-source branch from ba0057f to 1b75321 Compare June 19, 2025 18:42

ps48 added 2 commits June 19, 2025 11:44

remove dupe in settings

00027e4

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

remove junit and mockito

707889f

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

dlvenable requested changes Jun 20, 2025

View reviewed changes

ps48 added 2 commits June 25, 2025 07:25

update config fields and move certs

41b18fb

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

update tests with new config options

a2da4a0

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

dlvenable requested changes Jun 25, 2025

View reviewed changes

ps48 added 2 commits June 25, 2025 10:10

use data prepper duration and add generic output_format

10b0968

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

update timeouts to duration

3a9e7be

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

dlvenable requested changes Jun 25, 2025

View reviewed changes

dlvenable approved these changes Jun 25, 2025

View reviewed changes

dlvenable requested changes Jun 25, 2025

View reviewed changes

update the output format defaults to null

c119aa8

Signed-off-by: Shenoy Pratik <sgguruda@amazon.com>

dlvenable approved these changes Jun 25, 2025

View reviewed changes

kkondaka approved these changes Jun 25, 2025

View reviewed changes

kkondaka merged commit 5ad289d into opensearch-project:main Jun 26, 2025
69 of 74 checks passed

kkondaka added the backport 2.12 label Jun 26, 2025

opensearch-trigger-bot bot mentioned this pull request Jun 26, 2025

[Backport 2.12] OTLP Source unified endpoint for logs, traces and metrics #5832

Merged

dlvenable mentioned this pull request Jun 26, 2025

[RFC] OTel telemetry unified source #5596

Closed

ps48 mentioned this pull request Sep 24, 2025

[DOC] OpenSearch Data prepper unified otlp source opensearch-project/documentation-website#11029

Closed

4 tasks

		import java.util.function.Function;


		public class CreateServer {


		import org.opensearch.dataprepper.plugins.server.ServerConfiguration;

		public class ConvertConfiguration {

		testImplementation 'org.junit.jupiter:junit-jupiter-api:5.8.1'
		testImplementation 'org.mockito:mockito-core:4.0.0'

	@JsonProperty("flush_interval")
	@DurationMin(seconds = 60)
	@DurationMax(seconds = 3600)
	private Duration flushInterval = Duration.ofSeconds(DEFAULT_FLUSH_INTERVAL);

Conversation

ps48 commented May 4, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Description

Issues Resolved

Check List

Uh oh!

KarstenSchnitter left a comment

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Uh oh!

ps48 commented May 6, 2025

Uh oh!

KarstenSchnitter left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

ps48 commented May 9, 2025

Uh oh!

KarstenSchnitter left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

ps48 commented May 30, 2025

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

ps48 commented May 4, 2025 •

edited

Loading