Каждое утро, когда я запускаю свое приложение на основе Spring-Cloud-Stream и Spring-Cloud-Stream-Binder-Kinesis, потребитель ждет минимум 5 минут, пока не получит первое сообщение.При следующей перезагрузке приложения потребители не ждут эти 5 минут.
Простой потребитель, подобный этому.
@StreamListener(StreamProcessor.INPUT_BOOKING)
public void incoming(Message<Booking> booking) {
//doSomething
}
Это мои свойства для привязки канала
spring.cloud.stream.bindings.inputBooking.destination=input-booking-stream
spring.cloud.stream.bindings.inputBooking.group=booking-consumers
Я пытался настроить startTimeout на связывателе каналов, но поведение такое же
spring.cloud.stream.kinesis.bindings.inputBooking.consumer.startTimeout=1000
Есть некоторые настройки для потоков Kinesis или Spring-Cloud-Stream-Binder-Kinesis, чтобы избежать этого времени ожидания?