запрос батча, по истечении которого закачка батча отменяется и все уже полученное выбрасывается. Сейчас специально просмотрел документацию и ничего нового по теме не обнаружил. Я ошибаюсь?
By setting fetch.min.bytes, you tell Kafka to wait until it has enough data to send before responding to the consumer. fetch.max.wait.ms lets you control how long to wait. By default, Kafka will wait up to 500 ms. If you set fetch.max.wait.ms to 100 ms and fetch.min.bytes to 1 MB, Kafka will recieve a fetch request from the consumer and will respond with data either when it has 1 MB of data to return or after 100 ms, whichever happens first.
Обсуждают сегодня