Consommation par lots et modes d’accusé de réception
Apprenez à consommer les enregistrements Kafka par lots et à choisir le mode d’accusé de réception adapté pour équilibrer débit, latence et garanties de livraison.
Consommation par lots et modes d’accusé de réception est une leçon Advanced Spring Boot 4: Event-Driven Architecture (Kafka) gratuite sur CoddyKit. Ceci est la leçon 4 sur 4. Tu peux lire la leçon complète ci-dessous gratuitement — puis la pratiquer en direct dans le navigateur avec un éditeur de code intégré et un tuteur IA 24/7. Elle fait partie du parcours d'apprentissage Advanced Spring Boot 4: Event-Driven Architecture (Kafka), et ta progression se synchronise sur le web et l'application CoddyKit. Le cours Advanced Spring Boot 4: Event-Driven Architecture (Kafka) comprend 4 leçons au total.
Certaines parties de cette leçon n'ont pas encore été traduites et s'affichent en anglais.
Why Batch Consumption
By default a @KafkaListener processes one record at a time. For high-throughput pipelines, processing records in batches reduces overhead and lets you bulk-write to databases.
Enabling Batch Mode
Set batch-listener to true on the container factory, or configure it in properties.
spring:
kafka:
listener:
type: batchA Batch Listener Method
When batch mode is on, your listener accepts a List of payloads instead of a single value.
@KafkaListener(topics = "orders")
public void handle(List<Order> orders) {
log.info("Received batch of {}", orders.size());
orderRepository.saveAll(orders);
}Accessing Batch Metadata
You can also receive the full list of ConsumerRecord objects to read keys, partitions, and offsets per record.
@KafkaListener(topics = "orders")
public void handle(List<ConsumerRecord<String,Order>> records) {
for (var r : records) {
process(r.value(), r.partition(), r.offset());
}
}Controlling Batch Size
The batch size is bounded by max.poll.records. Tune it to control how many records each poll fetches.
spring:
kafka:
consumer:
max-poll-records: 500Acknowledgment Modes Overview
Spring Kafka offers several AckMode values:
BATCH— commit offsets after the whole batch.RECORD— commit after each record.MANUAL/MANUAL_IMMEDIATE— you call ack explicitly.
Setting AckMode
Configure the ack mode on the listener container factory.
factory.getContainerProperties()
.setAckMode(ContainerProperties.AckMode.BATCH);Manual Acknowledgment in Batches
With MANUAL mode, inject an Acknowledgment and call acknowledge() only after successful processing of the batch.
@KafkaListener(topics = "orders")
public void handle(List<Order> orders, Acknowledgment ack) {
orderRepository.saveAll(orders);
ack.acknowledge();
}Delivery Guarantees
Acknowledging after processing gives at-least-once delivery: if the app crashes mid-batch, the batch is redelivered.
Make your batch processing idempotent so reprocessing is safe.
Throughput vs Latency
Larger batches improve throughput but increase per-message latency and memory use. Start with a moderate max.poll.records and measure.
Putting It Together
Batch consumption plus the right ack mode lets you build efficient, reliable consumers. Combine type: batch, a tuned poll size, manual ack, and idempotent writes.
Quick Check
Test your understanding of batch consumption.
Recap
You learned batch consumption and acknowledgment modes.
- Set
type: batchto receive a List of records. - Tune
max.poll.recordsfor batch size. - Choose an
AckModeto control offset commits. - Acknowledge after processing and keep writes idempotent.
Questions Fréquemment Posées
La leçon « Consommation par lots et modes d’accusé de réception » est-elle gratuite ?
Oui — le texte complet de « Consommation par lots et modes d’accusé de réception » est gratuit à lire ici sur le web. Pour la pratiquer de manière interactive (un éditeur de code intégré et un tuteur IA 24/7) et déverrouiller le reste du cours Advanced Spring Boot 4: Event-Driven Architecture (Kafka), passe à CoddyKit PRO. Le cours Advanced Spring Boot 4: Event-Driven Architecture (Kafka) comprend 4 leçons au total.
Qu'est-ce que j'apprendrai dans « Consommation par lots et modes d’accusé de réception » ?
Apprenez à consommer les enregistrements Kafka par lots et à choisir le mode d’accusé de réception adapté pour équilibrer débit, latence et garanties de livraison. Tu pratiques Advanced Spring Boot 4: Event-Driven Architecture (Kafka) avec du code pratique que tu exécutes directement dans le navigateur, et un tuteur IA 24/7 répond à tes questions au fur et à mesure que tu avances dans la leçon.
Dois-je avoir de l'expérience pour commencer Advanced Spring Boot 4: Event-Driven Architecture (Kafka) ?
Aucune expérience préalable n'est requise. Advanced Spring Boot 4: Event-Driven Architecture (Kafka) sur CoddyKit est structuré pour les débutants jusqu'aux apprenants avancés, donc tu peux commencer ici ou depuis le début et avancer à ton rythme. Ceci est la leçon 4 sur 4.
Combien de temps prend la leçon « Consommation par lots et modes d’accusé de réception » ?
La plupart des leçons CoddyKit prennent environ 5–10 minutes. Chacune est courte et interactive, tu progresses régulièrement et tu repiques exactement où tu t'es arrêté sur le web et l'app.
Peux-tu écrire et exécuter du code dans cette leçon Advanced Spring Boot 4: Event-Driven Architecture (Kafka) ?
Oui. Chaque leçon Advanced Spring Boot 4: Event-Driven Architecture (Kafka) inclut un éditeur de code intégré, tu écris et exécutes du vrai code directement dans ton navigateur et tu reçois des retours IA instantanés — aucune configuration locale requise.
Toutes les leçons de ce cours
- Créer des conteneurs d’écoute Kafka
- Gestion des groupes de consommateurs
- Désérialisation et conversion des messages
- Consommation par lots et modes d’accusé de réception