Что такое Pull модель в брокерах сообщений

Pull модель в брокерах сообщений — это подход, при котором потребитель (consumer) сам запрашивает сообщения из очереди, когда готов их обработать. В отличие от push-модели, где брокер активно отправляет сообщения потребителям, здесь инициатива на стороне клиента.

Пример с Kafka:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList("my-topic"));

while (true) {
ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
for (ConsumerRecord<String, String> record : records) {
System.out.printf("offset = %d, key = %s, value = %s%n",
record.offset(), record.key(), record.value());
}
}

**Плюсы:**
- Контроль скорости обработки на стороне потребителя
- Возможность batch-обработки
- Меньшая нагрузка на брокер

**Минусы:**
- Задержки из-за периодического опроса
- Риск пустых опросов (нет сообщений)