Nous utilisons kafka pour le traitement des flux dans notre système. La structure des données d'entrée \ message est très complexe. alors comment définir la structure du message d'entrée. qui est le mécanisme de structure et de sérialisation le plus approprié pour les données d'entrée \ message.kafka format de message pour les données complexes message
0
A
Répondre
0
Vous pouvez utiliser les sérialiseurs ci-dessous pour sérialiser vos messages d'entrée.
- Apache commons lang3 serializer - plus facile la mise en œuvre
- Kryo Serialization - rapide et efficace sérialiseur
- Avro Serialization - prend en charge l'évolution du schéma au fil du temps avec le registre
Je vous recommande de mettre en œuvre la serailizer Kryo.
Quelle est la source de données et comment la structure de données est-elle définie dans le système source? –