diff --git a/data-prepper-plugins/otel-logs-source/src/main/java/org/opensearch/dataprepper/plugins/source/otellogs/OTelLogsSource.java b/data-prepper-plugins/otel-logs-source/src/main/java/org/opensearch/dataprepper/plugins/source/otellogs/OTelLogsSource.java index d34cf2c68e..f5fea32b22 100644 --- a/data-prepper-plugins/otel-logs-source/src/main/java/org/opensearch/dataprepper/plugins/source/otellogs/OTelLogsSource.java +++ b/data-prepper-plugins/otel-logs-source/src/main/java/org/opensearch/dataprepper/plugins/source/otellogs/OTelLogsSource.java @@ -62,7 +62,9 @@ import java.util.concurrent.ExecutionException; import java.util.concurrent.ScheduledThreadPoolExecutor; -@DataPrepperPlugin(name = "otel_logs_source", pluginType = Source.class, pluginConfigurationType = OTelLogsSourceConfig.class) +@DataPrepperPlugin(name = "otlp_logs", + deprecatedName = "otel_logs_source", + pluginType = Source.class, pluginConfigurationType = OTelLogsSourceConfig.class) public class OTelLogsSource implements Source> { private static final Logger LOG = LoggerFactory.getLogger(OTelLogsSource.class); static final String SERVER_CONNECTIONS = "serverConnections"; diff --git a/data-prepper-plugins/otel-metrics-source/src/main/java/org/opensearch/dataprepper/plugins/source/otelmetrics/OTelMetricsSource.java b/data-prepper-plugins/otel-metrics-source/src/main/java/org/opensearch/dataprepper/plugins/source/otelmetrics/OTelMetricsSource.java index a48d80280a..9f21f32cbb 100644 --- a/data-prepper-plugins/otel-metrics-source/src/main/java/org/opensearch/dataprepper/plugins/source/otelmetrics/OTelMetricsSource.java +++ b/data-prepper-plugins/otel-metrics-source/src/main/java/org/opensearch/dataprepper/plugins/source/otelmetrics/OTelMetricsSource.java @@ -37,9 +37,11 @@ import java.util.Collections; import java.util.concurrent.ExecutionException; -@DataPrepperPlugin(name = "otel_metrics_source", pluginType = Source.class, pluginConfigurationType = OTelMetricsSourceConfig.class) +@DataPrepperPlugin(name = "otlp_metrics", + deprecatedName = "otel_metrics_source", + pluginType = Source.class, pluginConfigurationType = OTelMetricsSourceConfig.class) public class OTelMetricsSource implements Source> { - private static final String PLUGIN_NAME = "otel_metrics_source"; + private static final String PLUGIN_NAME = "otlp_metrics"; private static final Logger LOG = LoggerFactory.getLogger(OTelMetricsSource.class); static final String SERVER_CONNECTIONS = "serverConnections"; diff --git a/data-prepper-plugins/otel-trace-source/src/main/java/org/opensearch/dataprepper/plugins/source/oteltrace/OTelTraceSource.java b/data-prepper-plugins/otel-trace-source/src/main/java/org/opensearch/dataprepper/plugins/source/oteltrace/OTelTraceSource.java index 374f6d4c1a..25e2c3dc86 100644 --- a/data-prepper-plugins/otel-trace-source/src/main/java/org/opensearch/dataprepper/plugins/source/oteltrace/OTelTraceSource.java +++ b/data-prepper-plugins/otel-trace-source/src/main/java/org/opensearch/dataprepper/plugins/source/oteltrace/OTelTraceSource.java @@ -39,9 +39,10 @@ import java.nio.charset.StandardCharsets; import java.util.concurrent.ExecutionException; -@DataPrepperPlugin(name = "otel_trace_source", pluginType = Source.class, pluginConfigurationType = OTelTraceSourceConfig.class) +@DataPrepperPlugin(name = "otlp_traces", + deprecatedName = "otel_trace_source", + pluginType = Source.class, pluginConfigurationType = OTelTraceSourceConfig.class) public class OTelTraceSource implements Source> { - private static final String PLUGIN_NAME = "otel_trace_source"; private static final Logger LOG = LoggerFactory.getLogger(OTelTraceSource.class);