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
3
A
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
- 1. Comptage Nombre de messages stockés dans un sujet kafka
- 2. Configuration de l'ACL pour le sujet kafka
- 3. Nombre maximal de messages pouvant être stockés dans une partition de sujet Kafka?
- 4. Comment créer un sujet durable dans kafka
- 5. kafka: Impossible de lier: erreur de sujet
- 6. Obtenir le nombre de messages dans un sujet PHP
- 7. Lire les données de la partition spécifique du sujet dans le courtier Kafka via Spark Streaming
- 8. Storm Kafkaspout KryoSerialization problème pour java haricot de kafka sujet
- 9. Kafka ne remplit pas les partitions uniformément dans un sujet
- 10. Récupération des catégories pour un sujet spécifique de DBpedia
- 11. Récupérer le nombre de messages JMS réessayer
- 12. Comment faire pour récupérer le nombre total
- 13. Obtenir nouveau nombre de messages pour chaque sujet en fonction de la dernière vue de l'utilisateur
- 14. Comment puis-je récupérer les types pour un sujet
- 15. Flume 1.7 & Kafka - Comment redémarrer au début du sujet?
- 16. Configurer l'aide de VS 2010 pour un sujet spécifique
- 17. Apache Storm ne recevant pas de messages de kafka
- 18. Comment choisir le sujet Kafka dynamiquement avec Spring Cloud Stream
- 19. Garder une série de messages dans un MQTT Sujet
- 20. Programatically (JAVA) Créer/Supprimer la partition de Kafka Sujet
- 21. Utilisation de XPath pour récupérer substring après un texte spécifique
- 22. Kafka: Comment obtenir la dernière modification d'un sujet ie le dernier message ajouté à une partition du sujet
- 23. Création d'un programme dans le sujet kafka à l'aide de la bibliothèque Microsoft/CSharpClient-pour-Kafka .NET
- 24. Logique pour un nombre spécifique
- 25. KafkaStream ne pas recevoir de messages du sujet
- 26. Comment faire pour grep un entier spécifique
- 27. Existe-t-il un outil pour modifier les messages de sujet JMS durables?
- 28. Différents nombre de messages (WordPress)
- 29. Requête qui récupère des messages pour un utilisateur spécifique
- 30. SQL Query: Comment faire plusieurs comptes? (Renvoyer le nombre de messages ainsi que le nombre de sujets pour chaque forum)
Si vous affichez un code représentatif, il sera beaucoup plus facile pour quelqu'un de vous aider. –
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