Package software.amazon.awscdk.services.pipes.sources.alpha

Class KinesisSource

java.lang.Object

software.amazon.jsii.JsiiObject

software.amazon.awscdk.services.pipes.alpha.SourceWithDeadLetterTarget

software.amazon.awscdk.services.pipes.sources.alpha.StreamSource

software.amazon.awscdk.services.pipes.sources.alpha.KinesisSource

All Implemented Interfaces:

ISource, software.amazon.jsii.JsiiSerializable

@Generated(value="jsii-pacmak/1.118.0 (build 02eec31)",
           date="2025-11-10T13:40:18.639Z")
@Stability(Experimental)
public class KinesisSource
extends StreamSource

(experimental) A source that reads from Kinesis.

Example:

 Stream sourceStream;
 Queue targetQueue;
 KinesisSource pipeSource = KinesisSource.Builder.create(sourceStream)
         .startingPosition(KinesisStartingPosition.LATEST)
         .build();
 Pipe pipe = Pipe.Builder.create(this, "Pipe")
         .source(pipeSource)
         .target(new SqsTarget(targetQueue))
         .build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	KinesisSource.Builder	(experimental) A fluent builder for KinesisSource.

Nested classes/interfaces inherited from class software.amazon.jsii.JsiiObject

software.amazon.jsii.JsiiObject.InitializationMode

Nested classes/interfaces inherited from interface software.amazon.awscdk.services.pipes.alpha.ISource

ISource.Jsii$Default

Constructor Summary

Constructors

Modifier	Constructor	Description
	KinesisSource(IStream stream, KinesisSourceParameters parameters)
protected	KinesisSource(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
protected	KinesisSource(software.amazon.jsii.JsiiObjectRef objRef)

Method Summary

Modifier and Type	Method	Description
SourceConfig	bind(IPipe _pipe)	(experimental) Bind the source to a pipe.
void	grantRead(IRole grantee)	(experimental) Grant the pipe role read access to the source.

Methods inherited from class software.amazon.awscdk.services.pipes.sources.alpha.StreamSource

getSourceArn, getSourceParameters

Methods inherited from class software.amazon.awscdk.services.pipes.alpha.SourceWithDeadLetterTarget

getDeadLetterTarget, getDeadLetterTargetArn, getDeadLetterTargetArn, grantPush, grantPush, isSourceWithDeadLetterTarget

Methods inherited from class software.amazon.jsii.JsiiObject

jsiiAsyncCall, jsiiAsyncCall, jsiiCall, jsiiCall, jsiiGet, jsiiGet, jsiiSet, jsiiStaticCall, jsiiStaticCall, jsiiStaticGet, jsiiStaticGet, jsiiStaticSet, jsiiStaticSet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface software.amazon.jsii.JsiiSerializable

$jsii$toJson

Constructor Details

KinesisSource

protected KinesisSource(software.amazon.jsii.JsiiObjectRef objRef)

KinesisSource

protected KinesisSource(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

KinesisSource

@Stability(Experimental)
public KinesisSource(@NotNull
 IStream stream,
 @NotNull
 KinesisSourceParameters parameters)

Parameters:

stream - This parameter is required.

parameters - This parameter is required.

Method Details

bind

@Stability(Experimental)
@NotNull
public SourceConfig bind(@NotNull
 IPipe _pipe)

(experimental) Bind the source to a pipe.

Specified by:

bind in interface ISource

Specified by:

bind in class SourceWithDeadLetterTarget

Parameters:

_pipe - This parameter is required.

grantRead

@Stability(Experimental)
public void grantRead(@NotNull
 IRole grantee)

(experimental) Grant the pipe role read access to the source.

Specified by:

grantRead in interface ISource

Specified by:

grantRead in class SourceWithDeadLetterTarget

Parameters:

grantee - This parameter is required.