Class KinesisConsumer


  • public class KinesisConsumer
    extends Object
    Responsible to connect to the configured Kinesis streams and start the scheduler threads to begin polling records
    Author:
    Fabio Ponciroli
    • Method Detail

      • subscribe

        public void subscribe()
      • shutdown

        public void shutdown()
        Stop the scheduler threads to end consuming records from the Kinesis streams