From 4c017a8be0c89784da08304f3fca5a714cebd9b2 Mon Sep 17 00:00:00 2001 From: Souvik Bose Date: Mon, 11 Nov 2024 15:29:21 -0800 Subject: [PATCH] Change name of Kinesis source plugin Signed-off-by: Souvik Bose --- .../dataprepper/plugins/kinesis/source/KinesisSource.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/data-prepper-plugins/kinesis-source/src/main/java/org/opensearch/dataprepper/plugins/kinesis/source/KinesisSource.java b/data-prepper-plugins/kinesis-source/src/main/java/org/opensearch/dataprepper/plugins/kinesis/source/KinesisSource.java index 2138c9a629..192d91d2e3 100644 --- a/data-prepper-plugins/kinesis-source/src/main/java/org/opensearch/dataprepper/plugins/kinesis/source/KinesisSource.java +++ b/data-prepper-plugins/kinesis-source/src/main/java/org/opensearch/dataprepper/plugins/kinesis/source/KinesisSource.java @@ -27,7 +27,12 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; -@DataPrepperPlugin(name = "kinesis", alternateNames = "kinesis-data-streams", pluginType = Source.class, pluginConfigurationType = KinesisSourceConfig.class) +@DataPrepperPlugin( + name = "kinesis", + alternateNames = { "kinesis-data-streams", "kinesis_data_streams" }, + pluginType = Source.class, + pluginConfigurationType = KinesisSourceConfig.class +) public class KinesisSource implements Source> { private static final Logger LOG = LoggerFactory.getLogger(KinesisSource.class); private final KinesisSourceConfig kinesisSourceConfig;