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