Acquire data from Kafka streams entity_1, entity_3 and relation_holding, import into Ultipa graphset shareholding:

1. Générer un fichier de configuration d'échantillon

./ultipa-importer --sample

2. Modifier le fichier de configuration

# Configurer le type de source de données
mode: kafka

# Configurer les informations sur la source de données
kafka:
  host: "192.168.1.1:5432"

# Configurer le serveur Ultipa
server:
  # Serveur Ultipa, utiliser une virgule ',' pour séparer plusieurs nœuds de serveur du cluster
  host: "192.168.2.149:60075"
  username: "admin"
  password: "abcd1234"
  # Nom du graphset, ou utiliser le graphset 'default' par défaut
  graphset: "shareholding"
  # Le répertoire du certificat SSL lorsque le serveur et le client Ultipa sont tous deux en mode SSL
  crt: ""

# Configurer les données de node
nodeConfig:
  - schema: "human"
    topic: "entity_1"
    offset: newest
    properties:
      - name: id
        type: _id
      - name: name
        type: string
      - name: type
        type: _ignore
  - schema: "firm"
    topic: "entity_3"
    offset: newest
    properties:
      - name: id
        type: _id
      - name: name
        type: string
      - name: type
        type: _ignore

# Configurer les données d'edge
edgeConfig:
  - schema: "hold"
    topic: "relation_holding"
    offset: newest
    properties:
      - name: from
        type: _from
      - name: to
        type: _to
      - name: shareInt
        type: int32
        new_name: share
      - name: type
        type: _ignore
        
# Configurer les paramètres globaux
settings:
  batchSize: 10000
  importMode: insert
  # créer automatiquement le graph, le schema, et les propriétés si non existants
  yes: true

3. Exécuter l'importation

./ultipa-importer --config ./import.sample.kafka.yml