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;