Когда потребитель потока Kinesis обнаруживает ошибку и возникает исключение в методе, помеченном @StreamListener
, как можно настроить привязку так, чтобы сообщение помещалось в очередь или отправлялось в DLQ? Я вижу этот уровень поддержки Rabbit и Kafka в Spring Cloud Stream, но я не вижу его для привязки Kinesis. Каков рекомендуемый подход для обработки ошибок в потоковом процессоре Kinesis? Как это сделать с помощью конфигурации и / или кода?