Class KinesisClientFactory


  • public final class KinesisClientFactory
    extends Object
    Factory class to return the correct type of AWS Kinesis client.
    • Method Detail

      • getKinesisClient

        public static KinesisInternalClient getKinesisClient​(Kinesis2Configuration configuration)
        Return the correct aws Kinesis client (based on remote vs local).
        Parameters:
        configuration - configuration
        Returns:
        KinesisClient