Обработка ошибок связующего устройства Spring Cloud Stream - PullRequest
0 голосов
/ 16 мая 2019

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

1 Ответ

2 голосов
/ 16 мая 2019

Реализация AWS Kinesis Binder полностью основана на Spring Cloud Stream Core и просто повторно использует свой общий подход для обработки ошибок: https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.2.0.RELEASE/spring-cloud-stream.html#spring-cloud-stream-overview-error-handling

Итак, вам нужно всего лишь @ServiceActivator для конкретного канала ошибок назначения и делать все, что вам нужно, с ошибочной записью.

В AWS Kinesis вообще нет функциональности DLQ / DLX / DLT, поэтому я не вижу причин злоупотреблять этим намерением и вводить что-то искусственное в Kinesis Binder.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...