IdleBetween пулы не вытягивают сообщения, как указано

Question

Я использую сообщения в пакетном режиме. Я хотел извлечь 8 сообщений каждые 250 мс из потока.

spring:  
  cloud:
    stream:
      kinesis:
        bindings:
          input:
            consumer:
              listenerMode: batch
              idleBetweenPolls: 250
              recordsLimit: 8
      bindings:
        input:
          group: my-group
          destination: stream
          content-type: application/json

Я отправил около 100 сообщений в поток и запустил потребителя.

Согласно конфигурации, я должен получать сообщения каждые 250 мс. Но опросчик не тянет сообщения каждые 250 мс.

@StreamListener(Sink.INPUT)
  public void receiveMessage(Message<List<byte[]>> messages) {
    log.info("Total received messages: " + messages.getPayload().size());
  }

2019-04-27 12:04:40.145 : Total received messages: 8
2019-04-27 12:04:41.604 : Total received messages: 8
2019-04-27 12:04:43.167 : Total received messages: 8
2019-04-27 12:04:44.618 : Total received messages: 8
2019-04-27 12:04:46.145 : Total received messages: 8
2019-04-27 12:04:47.775 : Total received messages: 8
2019-04-27 12:04:49.211 : Total received messages: 8
2019-04-27 12:04:50.756 : Total received messages: 8
2019-04-27 12:04:52.283 : Total received messages: 8
2019-04-27 12:04:53.817 : Total received messages: 8

Я даже ничего не обрабатываю. Это просто журнал.

Время между каждым сообщением превышает 250 мс. Я что-то упустил?

Answer 1

250 мс не имеет смысла для реалистичного варианта использования. Может быть, вы могли бы увеличить интервал до 5 секунд и попробовать.