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ètre | Description | Type 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 |
Vous avez un commentaire à formuler concernant cette rubrique ?