Kafka

La sortie Kafka dans ArcGIS Velocity vous permet d’envoyer des entités en sortie à une rubrique dans un broker Kafka accessible en externe. Un message Kafka est envoyé pour chaque entité en sortie envoyée à la sortie.

Pour en savoir plus sur Apache Kafka

Exemples

Les exemples suivants illustrent des cas d’utilisation de la sortie :

  • Un analyste configure une analyse en temps réel afin de traiter et d’analyser les événements ingérés par un flux, puis envoie les entités résultantes à une rubrique Kafka.
  • Un analyste financier envoie des mises à jour temps réel concernant des transactions boursières à une rubrique Kafka, permettant ainsi un accès instantané aux données.
  • Après avoir effectué une analyse dans le cadre d’une analyse Big Data, un chercheur veut envoyer les entités spatiales ou tabulaires en sortie à Kafka.

Remarques sur l’utilisation

Gardez les points suivants à l’esprit lorsque vous utilisez la sortie :

  • Le broker Kafka doit être accessible en externe via Internet.
  • Les formats de données en sortie disponibles sont les suivants :
    • Délimité
    • JSON
    • GeoJSON
    • EsriJSON

Paramètres

Les paramètres de la sortie sont les suivants :

ParamètreDescriptionType de données
Brokers

Liste délimitée par des virgules des brokers Kafka, spécifiés comme server:port, par exemple : machine1.domain.com:9092,machine2.domain.com:9092,machine3.domain.com:9092.

Chaîne

Rubrique

Rubrique Kafka vers laquelle la sortie envoie les messages.

Chaîne

Authentification

Spécifie le type d’authentification pour accéder à l’extrémité HTTP. Les options d’authentification sont les suivantes :

  • Aucun
  • SASL/PLAIN
  • SASL/SCRAM-SHA-256
  • SASL/SCRAM-SHA-512

Chaîne

Use SSL (Utiliser SSL)

Indique si Velocity utilise SSL (SASL_SSL) lorsqu’il tente de se connecter à l’agent Kafka.

Remarque :

Doit correspondre à la configuration de l'agent sur le port spécifié. Si vous désactivez ce paramètre, Velocity se connecte avec PLAINTEXT.

Booléen

Nom d’utilisateur

Spécifie le nom d’utilisateur pour accéder au broker Kafka.

Ce paramètre ne s’applique que lorsque la valeur de Authentication (Authentification) est définie sur SASL/PLAIN, SASL/SCRAM-SHA-256 ou SASL/SCRAM-SHA-512.

Chaîne

Mot de passe

Spécifie le mot de passe pour accéder au broker Kafka.

Ce paramètre ne s’applique que lorsque la valeur de Authentication (Authentification) est définie sur SASL/PLAIN, SASL/SCRAM-SHA-256 ou SASL/SCRAM-SHA-512.

Chaîne

Nom du champ en sortie

Format des messages sortants. Les noms de format de sortie pris en charge sont les suivants :

  • GeoJSON
  • EsriJSON
  • Délimité
  • JSON

Chaîne

Écrire des lignes d’en-tête

Indique si les fichiers écrivent la ligne d’en-tête avec les noms de champ. Par défaut, cette propriété est définie sur faux.

Booléen

Délimiteur de champ

Délimiteur de champ utilisé par le fichier pour séparer les champs. La virgule est le caractère utilisé par défaut.

Chaîne