0
J'ai consommé quelques messages de la file d'attente de Kafka, et maintenant je veux les consommer de nouveau (juste chercher toutes les données depuis le début). Comment puis-je réinitialiser le décalage dans Scala ou en utilisant Kafka Rest Proxy? J'utilise actuellement "auto.offset.reset": "smallest":Comment réinitialiser le décalage pour la consommation de messages Kafka?
curl -X POST -H "Content-Type: application/vnd.kafka.v1+json" \
--data '{"format": "json", "auto.offset.reset": "smallest"}' \
XXX.XX.XXX.XXX:9092/consumers/test
S'il vous plaît notez que je ne suis pas intéressé par la solution
Quelle bibliothèque client utilisez-vous pour consommer les messages? Pouvez-vous coller dans le code? Aussi - _not intéressé par la solution_? – Dani