0

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

Quelle est la source de données et comment la structure de données est-elle définie dans le système source? –

Répondre

0

Vous pouvez utiliser les sérialiseurs ci-dessous pour sérialiser vos messages d'entrée.

  1. Apache commons lang3 serializer - plus facile la mise en œuvre
  2. Kryo Serialization - rapide et efficace sérialiseur
  3. 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.