-noprompt
```
{% endcode %}
* **Alias :** alias du certificat dans le keystore
* **Import-file**: nom du fichier de certificat contenant le certificat fourni
* **Storepass** et **keypass :** mot de passe pour protéger votre keystore, doivent être identiques
Pour lister le contenu de votre keystore, utilisez cette commande :
```bash
keytool -list -v -keystore kafka.client.truststore.jks
```
#### Fichier de propriétés
Une fois le keystore créé, il vous faut maintenant un fichier de propriétés :
```ini
security.protocol=SASL_SSL
sasl.mechanism=SCRAM-SHA-256
sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="user" password="password";
ssl.truststore.location=/path/to/kafka.client.truststore.jks
ssl.truststore.password=keystore-password
```
* **username :** le super utilisateur kafka qui vous est fourni par email
* **mot de passe :** le mot de passe de cet utilisateur que vous avez fourni lors du provisionnement.
* **ssl.truststore.location :** l'emplacement de votre keystore précédemment créé
* **ssl.truststore.password :** le mot de passe pour déverrouiller votre keystore (storepass / keypass utilisé)
#### Ligne de commande
Avec ces éléments, vous pouvez maintenant utiliser n'importe quel script shell Kafka avec le paramètre suivant :
```
--command-config client.properties
```
### Gérer les topics
#### Créer un topic
{% code overflow="wrap" %}
```
# Use an env variable for short commands, the bootstrap-server is available in ITCare
export BROKERS=broker1.hosting.cegedim.cloud:9094,broker2.hosting.cegedim.cloud:9094,broker3.hosting.cegedim.cloud:9094
```
{% endcode %}
kafka-topics.sh --bootstrap-server $BROKERS --create --replication-factor 3 --partitions 3 --topic my-topic --command-config client.properties
Created topic my-topic.
#### Lister des topics
kafka-topics.sh --bootstrap-server $BROKERS -list --command-config client.properties my-topic
#### Décrire un topic
kafka-topics.sh --bootstrap-server $BROKERS --describe --topic my-topic --command-config client.properties
Topic: my-topic TopicId: 84yqCErzTG27J4wv44dkPQ PartitionCount: 4 ReplicationFactor: 3 Configs: cleanup.policy=delete
Topic: my-topicc Partition: 0 Leader: 2 Replicas: 2,3,1 Isr: 2,3,1
Topic: my_topic Partition: 1 Leader: 3 Replicas: 3,1,2 Isr: 3,1,2
Topic: my_topic Partition: 2 Leader: 1 Replicas: 1,2,3 Isr: 1,2,3
Topic: my_topic Partition: 3 Leader: 2 Replicas: 2,1,3 Isr: 2,1,3
#### Supprimer un topic
kafka-topics.sh --bootstrap-server $BROKERS --delete --topic my-topic --command-config client.properties
#### Ajouter des partitions au topic
{% code overflow="wrap" %}
```
kafka-topics.sh --bootstrap-server $BROKERS --alter --topic my-topic --partitions 16 --command-config client.properties
```
{% endcode %}
#### Lister les partitions sous-répliquées pour tous les topics
{% code overflow="wrap" %}
```
kafka-topics.sh --bootstrap-server $BROKERS --describe --under-replicated-partitions --command-config client.properties
```
{% endcode %}
#### Lister les ACLs pour un topic
{% code overflow="wrap" %}
```
kafka-acls.sh --bootstrap-server $BROKERS --topic=my-topic --list --command-config client.properties
```
{% endcode %}
### Gérer les utilisateurs
#### Créer un utilisateur Kafka
{% code overflow="wrap" %}
```
kafka-configs.sh --bootstrap-server $BROKERS --alter --add-config 'SCRAM-SHA-256=[password=secret]' --entity-type users --entity-name username --command-config client.properties
```
{% endcode %}
#### Lister des utilisateurs de Kafka
{% code overflow="wrap" %}
```
kafka-configs.sh --bootstrap-server $BROKERS --describe --entity-type users --command-config client.properties
```
{% endcode %}
#### Supprimer un utilisateur Kafka
{% code overflow="wrap" %}
```
kafka-configs.sh --bootstrap-server $BROKERS --alter --delete-config 'SCRAM-SHA-256' --entity-type users --entity-name username --command-config client.properties
```
{% endcode %}
#### Lister tous les ACLs
{% code overflow="wrap" %}
```
kafka-acls.sh --bootstrap-server $BROKERS --list --command-config client.properties
```
{% endcode %}
#### Lister les ACL pour un utilisateur Kafka
{% code overflow="wrap" %}
```
kafka-acls.sh --bootstrap-server $BROKERS --principal User:admin --list --command-config client.properties
```
{% endcode %}
#### Définir des ACL pour un utilisateur Kafka
{% code overflow="wrap" %}
```
kafka-acls.sh --bootstrap-server $BROKERS --add --allow-principal User:alice --producer --topic my-topic --command-config client.properties
```
{% endcode %}
#### Supprimer un ACL pour un utilisateur Kafka
{% code overflow="wrap" %}
```
kafka-acls.sh --bootstrap-server $BROKERS --remove --allow-principal User:bob --consumer --topic my-topic --group my-consumer-group --command-config client.properties
```
{% endcode %}
### Producteurs
#### Lancer un producteur de message
{% code overflow="wrap" %}
```
kafka-console-producer.sh --broker-list $BROKERS --topic my-topic --producer.config client.properties
>
```
{% endcode %}
### Consommateurs
#### Lancer un consommateur
{% code overflow="wrap" %}
```
kafka-console-consumer.sh --bootstrap-server $BROKERS --topic my-topic --consumer.config client.properties --group consu
```
{% endcode %}
#### Lister tous les groupes de consommateurs
{% code overflow="wrap" %}
```
kafka-consumer-groups.sh --list --bootstrap-server $BROKERS --command-config client.properties
```
{% endcode %}
#### Décrire le groupe de consommateurs
{% code overflow="wrap" %}
```
kafka-run-class.sh kafka.admin.ConsumerGroupCommand --bootstrap-server $BROKERS --describe --group consu --command-config client.properties
```
{% endcode %}
#### Supprimer un groupe de consommateurs
{% code overflow="wrap" %}
```
kafka-consumer-groups.sh --bootstrap-server $BROKERS --group my-group --group my-other-group --delete --command-config client.properties
```
{% endcode %}
## Kcat
Kcat est un producteur et consommateur générique non-JVM pour Apache Kafka >=0.8.
{% embed url="" %}
La version 1.5.0 et supérieure doit être utilisée pour prendre en charge l'authentification SASL\_SSL.
De plus amples informations concernant Kcat sont disponibles sur le site de Confluent :
{% embed url="" %}
## Clients Kafka
Veuillez vous référer à cette documentation pour créer un client Kafka dans la langue de votre choix :
{% embed url="" %}
## Connecteurs Kafka
Veuillez vous référer à cette documentation pour en savoir plus sur les connecteurs Kafka :
{% embed url="" %}
## Ajouter un noeud broker Kafka
En haut de la page du cluster, cliquez sur le bouton **Gérer**, puis sur **Ajouter un nœud broker**. Sélectionnez la taille du disque et la zone de disponibilité.
Saisissez un numéro RFC pour le suivi (facultatif), puis cliquez sur **Soumettre**.
{% hint style="info" %}
Cette fonctionnalité n'est disponible que pour les versions Kafka 3.6 ou plus. Un seul nœud peut être créé à la fois. Le nom du nœud, la RAM ainsi que le CPU sont prédéfinis afin d'assurer la cohérence du cluster.
{% endhint %}
Une notification par courriel sera envoyée lorsque le nœud aura été créé.