Class KinesisSink

    • Field Detail

      • LOGGER

        public static final Logger LOGGER
    • Constructor Detail

      • KinesisSink

        public KinesisSink()
    • Method Detail

      • nullifyKinesisClient

        public static void nullifyKinesisClient()
      • rebuildKinesisClient

        public static void rebuildKinesisClient()
      • sendCloudEvent

        public void sendCloudEvent​(io.cloudevents.CloudEvent cloudEvent)
        Specified by:
        sendCloudEvent in class CDEventsSink