Merci beaucoup pour la conf, c'était très instructifs. Je me permet néanmoins de pointer une erreur ou imprécision sur kafka stream à 40:40 Dans le cas d'un état stocké sur rocksdb, Kafka stream stock le changelog de l'état dans un topic kafka suffixé changelog. Ce changelog remplace le changelog standard de rocksdb. Le même mécanisme existe pour les états stockés en mémoire, un topic de changelog est également créé. Par conséquent, si un noeud tombe, est ajouté ou qu'un rééquilibrage de charge a lieu, l'état sera reconstruit en rechargeant toutes les partitions du topic de changelog correspondant à l'état qu'il faut reconstruire. La vitesse de redémarrage est donc fonction de la charge de chaque partition sur le topic de changelog. Plus il y a de donnée dans la partition, plus il faudra du temps pour recréer l'état. Par conséquent, plus vous avez de partition, plus vous avez de flexibilité pour répartir la charge entre plusieurs noeud.
Пікірлер: 1