1
J'ai un scénario où je veux consommer le dernier message écrit sur un sujet de kafka au démarrage. Par exemple s'il y a un sujet "deal_config" avec une seule partition, et il y a trois messages comme 1 | 2 | 3, au démarrage, je veux consommer seulement le message 3. Si je mets à startOffset à latest je peux consommer seulement les nouveaux messages. Idéalement, mon client devrait lire le décalage du dernier message dans la partition et en consommer -1.SCS - pour consommer le dernier message disponible dans kafka
@GrayRussell. Puis-je utiliser KafkaListener dans un projet utilisant le liant S-C-S Kafka. Mon besoin est de jouer avec offset pour peu de sujets et tous les autres consommateurs lisent toujours le dernier offset. J'ai donc utilisé StreamListner et KafkaListener (avec consumerseekaware) dans le projet qui a Spring-Cloud-Stream-Binder-Kafka 1.2.1 et printemps-kafka 1.2.1 (surchargé). Mais le kafkaListner ne fonctionne jamais et aucune exception n'est levée. Les messages ne sont pas consommés et mes méthodes consumerseekaware ne sont pas invoquées. – Hariharan
Oui; vous pouvez utiliser les deux dans la même application. Posez une nouvelle question montrant des extraits de code de ce qui ne fonctionne pas pour vous. –
Merci @GrayRussell Je suis capable de faire les deux .. merci – Hariharan