2012-09-30 4 views
3

J'utilise la propriété queuedchunks.max pour récupérer 10 messages du sujet à la fois, mais il retourne tous les messages disponibles (plus de 10) .S'il vous plaît me faire savoir s'il y est un moyen de récupérer les messages requis uniquement.Comment faire pour récupérer un nombre spécifique de messages de Kafka Sujet

+1

Si vous affichez un code représentatif, il sera beaucoup plus facile pour quelqu'un de vous aider. –

+0

Puisque pour consommer des messages de kafka vous devez faire une boucle en récupérant chaque message un par un, pourquoi ne vous cassez-vous pas juste après le nombre de messages que vous vouliez? – C4stor

Répondre

-2

This link pourrait vous aider à comprendre.

S'il vous plaît faire définir la valeur de batch.size comme le montre kafka-configuration pour obtenir 10 messages d'un sujet à la fois.

Questions connexes