2016-04-08 1 views
0

Nous essayions de passer de kafka 0.8 à 0.9 et nous aimerions utiliser la gestion de compensation de kafka qui a été publiée dans le cadre de 0.9. Jusqu'à présent, nous stockions les offsets sur la base de données et écrivions à notre client personnalisé qui vérifiait les décalages dans la base de données et récupérait les messages de kafka. Comment pourrions-nous migrer ces offsets vers kafka? J'ai lu à propos de la migration de kafka offset de zookeeper à kafka mais je n'ai rien trouvé à ce sujet.kafka compense la migration de la base de données locale vers kafka

Répondre

0

Vous pouvez envoyer manuellement OffsetCommitRequest à kafka pour définir vos décalages actuels, puis commencer à utiliser un nouveau consommateur. Voir kafka wiki par exemple