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 plus d’informations concernant Kafka, reportez-vous à la rubrique Apache Kafka.

Exemples

L’exemple suivant utilise la sortie Kafka :

  • 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.
  • 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

Le broker Kafka doit être accessible en externe via Internet.

Paramètres

Les paramètres de la sortie Kafka 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 va envoyer les messages.

Chaîne

Authentification

Spécifie le type d’authentification pour accéder à l’extrémité HTTP. Les options d’authentification sont None (Aucune), SASL/PLAIN, SASL/SCRAM-SHA-256 et 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 ce paramètre est désactivé, Velocity se connecte via 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 formats délimité et JSON sont pris en charge.

Chaîne