0
Kafka garantit que les messages avec la même clé iront toujours à la même partition . Par exemple, j'ai un message avec la clé de chaîne: 2329. Et deux sujets t1 et t2. Lorsque j'effectue l'écriture de ce message, il va dans la partition 1 dans les deux sujets, comme prévu.Kafka Streams stratégie de partitionnement de sujet de sauvegarde de magasin d'état
Maintenant le problème lui-même: J'utilise Kafka Streams 0.10.2.0 stockage d'état persistant, qui crée automatiquement un sujet de sauvegarde. Maintenant, dans le cas de ce message de sauvegarde avec la clé: 2329 va dans une autre partition (partition 0), ce qui est étrange pour moi.
Est-ce que quelqu'un a rencontré ce problème?
Utilisez-vous le même sérialiseur? Le numéro de partition est déterminé par la valeur sérialisée de la clé. Si le Kafka Streams Serde utilise un sérialiseur différent de celui du Serializer utilisé par votre KafkaProducer, cela pourrait l'expliquer. –
Les sérialiseurs sont les mêmes, le partitionneur est par défaut. – user3735823