Можно ли создать собственный приемник, который может использовать непрерывный триггер? Пример кода реализации псевдо-кода может помочь. Пользовательский приемник, реализующий ForEachWriter, не допускает триггера Continuous. Мне нужен непрерывный процесс, который может записывать в Kinesis, а не триггер обработки (микропакет)