# Apache Kafka - Nœud de workflow | Docs - nodulz

Source: https://nodulz.com/fr/docs/nodes/kafka

Language: fr

Publier un message avec Apache Kafka

## Utilisation et spécificités

Sélectionnez l’identifiant du broker et la destination : topic Kafka ou MQTT, file RabbitMQ ou sujet NATS. Configurez groupId pour Kafka, exchange et routingKey pour RabbitMQ, qos et retain pour MQTT. Publiez les déclencheurs pour ouvrir la souscription ; un test simulé ne vérifie pas le broker. Prévoyez un traitement idempotent des messages.

Type technique : `kafka`. Runtime : `nodulz`.

## Identifiants et prérequis

- [Apache Kafka](/docs/credentials) (`integration` / `kafka`). Connexion chiffrée au broker Apache Kafka

Créez l’identifiant dans la rubrique Identifiants de votre instance nodulz, puis sélectionnez-le dans le nœud. Les identifiants disponibles dépendent du propriétaire et du partage. Consultez le [guide des identifiants](/docs/credentials) pour les accès et la rotation.

## Paramètres

Les noms ci-dessous correspondent aux clés techniques. Les valeurs par défaut ne constituent pas une configuration prête à exécuter : renseignez les champs requis par votre opération. Les chemins contenant [] décrivent les éléments d’une liste ; certains champs dépendent du mode sélectionné.

| Paramètre | Type | Par défaut | Valeurs / limites |
| --- | --- | --- | --- |
| `credentialId` | `string` | `""` | - |
| `destination` | `string` | `""` | - |
| `message` | `string` | `"{\"hello\":\"world\"}"` | - |
| `key` | `string` | `""` | - |
| `groupId` | `string` | `""` | - |
| `fromBeginning` | `boolean` | `false` | - |
| `exchange` | `string` | `""` | - |
| `routingKey` | `string` | `""` | - |
| `qos` | `number` | `1` | -; ≥ 0, ≤ 2 |
| `retain` | `boolean` | `false` | - |
| `testPayload` | `string` | `""` | - |

## Aide de configuration

| Réglage | Rôle et conseils |
| --- | --- |
| `credentialId`<br>Identifiant | Sélectionnez la connexion du même fournisseur. Elle est chiffrée et vérifiée avec les droits du propriétaire du workflow. |
| `fromBeginning`<br>Lire depuis le début | Kafka uniquement : point de départ si ce groupe n’a aucun offset enregistré. Les offsets existants restent prioritaires. |
| `qos`<br>Qualité de service (QoS) | MQTT : 0 au plus une fois, 1 au moins une fois, 2 exactement une fois au niveau du protocole. Ne garantit pas l’exécution unique du workflow. |
| `retain`<br>Conserver le dernier message | Le broker MQTT conserve le message pour les nouveaux abonnés. Un message vide efface cette valeur. |
| `testPayload`<br>Événement de test (JSON) | Facultatif. Remplace les champs de l’événement simulé pendant un test manuel, sans connexion au broker. |

## Configuration initiale

Exemple de configuration initiale du catalogue, à adapter avant exécution. Les secrets doivent rester dans les identifiants.

```json
{
  "credentialId": "",
  "destination": "",
  "message": "{\"hello\":\"world\"}",
  "key": "",
  "groupId": "",
  "fromBeginning": false,
  "exchange": "",
  "routingKey": "",
  "qos": 1,
  "retain": false,
  "testPayload": ""
}
```

## Vérification

Testez le nœud avec des données représentatives. Contrôlez sa sortie dans l’inspecteur et les logs, puis utilisez le mapping de l’éditeur pour les champs des nœuds suivants. Un test de déclencheur avec payload simulé ne valide pas la livraison du service externe.

Voir aussi : [Expressions et données](/docs/expressions), [Exécutions](/docs/executions), [Catalogue des nœuds](/docs/nodes).

## Pour aller plus loin

- [Fonctionnalités - nodulz](https://nodulz.com/fr/product/overview)
- [Catalogue des nœuds - nodulz](https://nodulz.com/fr/product/catalog)
- [Serveur MCP - nodulz](https://nodulz.com/fr/product/mcp)
- [Tarifs - nodulz](https://nodulz.com/fr/pricing)
- [Cas d’usage et automatisations - nodulz](https://nodulz.com/fr/use-cases)
- [Choisissez ce que vos workflows peuvent faire. - nodulz](https://nodulz.com/fr/compare)
- [Documentation - nodulz](https://nodulz.com/fr/docs)