Skip to content

Commit

Permalink
Change name of Kinesis source plugin
Browse files Browse the repository at this point in the history
Signed-off-by: Souvik Bose <souvbose@amazon.com>
  • Loading branch information
sbose2k21 committed Nov 12, 2024
1 parent 85f1718 commit 4c017a8
Showing 1 changed file with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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<Record<Event>> {
private static final Logger LOG = LoggerFactory.getLogger(KinesisSource.class);
private final KinesisSourceConfig kinesisSourceConfig;
Expand Down

0 comments on commit 4c017a8

Please sign in to comment.