Spring Cloud Stream Consumer получает одно и то же сообщение более одного - PullRequest
Новая
       22

Spring Cloud Stream Consumer получает одно и то же сообщение более одного

0 голосов
/ 28 марта 2019

мы слушаем тему, созданную другим API. Потребитель, обрабатывает сообщение, но иногда это занимает более 4-5 секунд. Затем весенний облачный поток отправляет такое же сообщение потребителю. Поэтому произошла ошибка на стороне потребителя. 

@StreamListener(ORDER_CREATED)
void orderCreated(Event event) {
  log.info("ORDER CREATED event received.")

  //process message
  //sometimes take a more than 4-5 seconds


  log.info("Order successfully STARTED.")
}

Должен ли потребитель потреблять сообщения как можно быстрее? Или должно быть асинхронно у потребителя?

...