Class KinesisStreamProvisioner

java.lang.Object

io.awspring.cloud.kinesis.stream.binder.provisioning.KinesisStreamProvisioner

All Implemented Interfaces:

org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>>

public class KinesisStreamProvisioner
extends Object
implements org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>>

The ProvisioningProvider implementation for Amazon Kinesis.

Since:

4.0

Author:

Peter Oates, Artem Bilan, Jacob Severson, Sergiu Pantiru, Matthias Wesolowski

Constructor Summary

Constructors

Constructor	Description
KinesisStreamProvisioner(software.amazon.awssdk.services.kinesis.KinesisAsyncClient amazonKinesis, KinesisBinderConfigurationProperties kinesisBinderConfigurationProperties)

Method Summary

Modifier and Type	Method	Description
org.springframework.cloud.stream.provisioning.ConsumerDestination	provisionConsumerDestination(String name, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties> properties)
org.springframework.cloud.stream.provisioning.ProducerDestination	provisionProducerDestination(String name, org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> properties)

Methods inherited from class java.lang.Object

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

Constructor Details

KinesisStreamProvisioner

public KinesisStreamProvisioner(software.amazon.awssdk.services.kinesis.KinesisAsyncClient amazonKinesis,
 KinesisBinderConfigurationProperties kinesisBinderConfigurationProperties)

Method Details

provisionProducerDestination

public org.springframework.cloud.stream.provisioning.ProducerDestination provisionProducerDestination(String name,
 org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> properties)
                                                                                               throws org.springframework.cloud.stream.provisioning.ProvisioningException

Specified by:

provisionProducerDestination in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>>

Throws:

org.springframework.cloud.stream.provisioning.ProvisioningException

provisionConsumerDestination

public org.springframework.cloud.stream.provisioning.ConsumerDestination provisionConsumerDestination(String name,
 String group,
 org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties> properties)
                                                                                               throws org.springframework.cloud.stream.provisioning.ProvisioningException

Specified by:

provisionConsumerDestination in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>>

Throws:

org.springframework.cloud.stream.provisioning.ProvisioningException