5.3. Les puits d'événements

Procédure

1. Créer une définition d'objet KafkaSink sous forme de fichier YAML :

   Evier Kafka YAML

   apiVersion: eventing.knative.dev/v1alpha1
   kind: KafkaSink
   metadata:
     name: <sink-name>
     namespace: <namespace>
   spec:
     topic: <topic-name>
     bootstrapServers:
      - <bootstrap-server>

   Copy to Clipboard Toggle word wrap

2. Pour créer le puits Kafka, appliquez le fichier YAML KafkaSink:

   $ oc apply -f <filename>

   Copy to Clipboard Toggle word wrap

3. Configurer une source d'événements de manière à ce que le puits soit spécifié dans sa spécification :

   Exemple d'un puits Kafka connecté à une source de serveur API

   apiVersion: sources.knative.dev/v1alpha2
   kind: ApiServerSource
   metadata:
     name: <source-name> 

   1

   
     namespace: <namespace> 

   2

   
   spec:
     serviceAccountName: <service-account-name> 

   3

   
     mode: Resource
     resources:
     - apiVersion: v1
       kind: Event
     sink:
       ref:
         apiVersion: eventing.knative.dev/v1alpha1
         kind: KafkaSink
         name: <sink-name> 

   4

   Copy to Clipboard Toggle word wrap

   1

   Le nom de la source de l'événement.

   2

   L'espace de noms de la source de l'événement.

   3

   Le compte de service pour la source de l'événement.

   4

   Le nom du puits Kafka.

Procédure

1. Dans la perspective Developer, accédez à la vue Add.
2. Cliquez sur Event Sink dans la page Eventing catalog.
3. Recherchez KafkaSink dans les éléments du catalogue et cliquez dessus.
4. Cliquez sur Create Event Sink.

5. Dans la vue du formulaire, saisissez l'URL du serveur d'amorçage, qui est une combinaison du nom d'hôte et du port.

   

   View larger image

   
6. Saisissez le nom de la rubrique à laquelle envoyer les données d'événement.
7. Saisissez le nom du puits d'événement.
8. Cliquez sur Create.

Vérification

1. Dans la perspective Developer, accédez à la vue Topology.
2. Cliquez sur le puits d'événement créé pour afficher ses détails dans le panneau de droite.

Procédure

1. Créez les fichiers de certificat en tant que secret dans le même espace de noms que votre objet KafkaSink:

   Important

   Les certificats et les clés doivent être au format PEM.

   • Pour l'authentification par SASL sans cryptage :

     $ oc create secret -n <namespace> generic <secret_name> \
       --from-literal=protocol=SASL_PLAINTEXT \
       --from-literal=sasl.mechanism=<sasl_mechanism> \
       --from-literal=user=<username> \
       --from-literal=password=<password>

     Copy to Clipboard Toggle word wrap

   • Pour l'authentification à l'aide de SASL et le cryptage à l'aide de TLS :

     $ oc create secret -n <namespace> generic <secret_name> \
       --from-literal=protocol=SASL_SSL \
       --from-literal=sasl.mechanism=<sasl_mechanism> \
       --from-file=ca.crt=<my_caroot.pem_file_path> \ 

     1

     
       --from-literal=user=<username> \
       --from-literal=password=<password>

     Copy to Clipboard Toggle word wrap

     1

     L'adresse ca.crt peut être omise pour utiliser le jeu de CA racine du système si vous utilisez un service Kafka géré dans un nuage public, tel que Red Hat OpenShift Streams pour Apache Kafka.

   • Pour l'authentification et le cryptage à l'aide de TLS :

     $ oc create secret -n <namespace> generic <secret_name> \
       --from-literal=protocol=SSL \
       --from-file=ca.crt=<my_caroot.pem_file_path> \ 

     1

     
       --from-file=user.crt=<my_cert.pem_file_path> \
       --from-file=user.key=<my_key.pem_file_path>

     Copy to Clipboard Toggle word wrap

     1

     L'adresse ca.crt peut être omise pour utiliser le jeu de CA racine du système si vous utilisez un service Kafka géré dans un nuage public, tel que Red Hat OpenShift Streams pour Apache Kafka.

2. Créez ou modifiez un objet KafkaSink et ajoutez une référence à votre secret dans la spécification auth:

   apiVersion: eventing.knative.dev/v1alpha1
   kind: KafkaSink
   metadata:
      name: <sink_name>
      namespace: <namespace>
   spec:
   ...
      auth:
        secret:
          ref:
            name: <secret_name>
   ...

   Copy to Clipboard Toggle word wrap

3. Appliquer l'objet KafkaSink:

   $ oc apply -f <filename>

   Copy to Clipboard Toggle word wrap