5.4. Courtiers

Vérification

1. La commande kn permet d'obtenir la liste de tous les courtiers existants :

   $ kn broker list

   Exemple de sortie

   NAME      URL                                                                     AGE   CONDITIONS   READY   REASON
   default   http://broker-ingress.knative-eventing.svc.cluster.local/test/default   45s   5 OK / 5     True

2. Facultatif : Si vous utilisez la console web de OpenShift Container Platform, vous pouvez naviguer vers la vue Topology dans la perspective Developer, et observer que le courtier existe :

   

Procédure

1. Créez un objet Trigger sous la forme d'un fichier YAML comportant l'annotation eventing.knative.dev/injection: enabled:

   apiVersion: eventing.knative.dev/v1
   kind: Trigger
   metadata:
     annotations:
       eventing.knative.dev/injection: enabled
     name: <trigger_name>
   spec:
     broker: default
     subscriber: 1
       ref:
         apiVersion: serving.knative.dev/v1
         kind: Service
         name: <service_name>

   1

   Spécifiez les détails du puits d'événements, ou subscriber, vers lequel le déclencheur envoie des événements.

2. Appliquer le fichier YAML Trigger:

   $ oc apply -f <filename>

1. Entrez la commande suivante oc pour obtenir le courtier :

   oc -n <namespace> get broker default

   Exemple de sortie

   NAME      READY     REASON    URL                                                                     AGE
   default   True                http://broker-ingress.knative-eventing.svc.cluster.local/test/default   3m56s

2. Facultatif : Si vous utilisez la console web de OpenShift Container Platform, vous pouvez naviguer vers la vue Topology dans la perspective Developer, et observer que le courtier existe :

   

1. Utilisez la commande oc pour obtenir le courtier :

   oc -n <namespace> get broker <broker_name>

   Example command

   $ oc -n default get broker default

   Exemple de sortie

   NAME      READY     REASON    URL                                                                     AGE
   default   True                http://broker-ingress.knative-eventing.svc.cluster.local/test/default   3m56s

2. Facultatif : Si vous utilisez la console web de OpenShift Container Platform, vous pouvez naviguer vers la vue Topology dans la perspective Developer, et observer que le courtier existe :

   

Procédure

1. Supprimer l'étiquette eventing.knative.dev/injection=enabled de l'espace de noms :

   oc label namespace <namespace> eventing.knative.dev/injection-

   La suppression de l'annotation empêche Knative de recréer le courtier après l'avoir supprimé.

2. Supprime le courtier de l'espace de noms sélectionné :

   oc -n <namespace> delete broker <broker_name>

Procédure

1. Dans la perspective Developer, naviguez vers Add Broker. La page Broker s'affiche.
2. Facultatif. Mettez à jour le site Name du courtier. Si vous ne mettez pas à jour le nom, le courtier généré s'appelle default.
3. Cliquez sur Create.

1. Dans la perspective Developer, naviguez jusqu'à Topology.

2. Consultez les composants mt-broker-ingress, mt-broker-filter, et mt-broker-controller.

   

Procédure

1. Dans la perspective Administrator de la console web OpenShift Container Platform, naviguez vers Serverless Eventing.
2. Dans la liste Create, sélectionnez Broker. Vous serez dirigé vers la page Create Broker.
3. En option : Modifier la configuration YAML du courtier.
4. Cliquez sur Create.

Procédure

1. Modifiez la carte de configuration kafka-broker-config ou créez votre propre carte de configuration qui contient la configuration suivante :

   apiVersion: v1
   kind: ConfigMap
   metadata:
     name: <config_map_name> 1
     namespace: <namespace> 2
   data:
     default.topic.partitions: <integer> 3
     default.topic.replication.factor: <integer> 4
     bootstrap.servers: <list_of_servers> 5

   1

   Le nom de la carte de configuration.

   2

   L'espace de noms dans lequel la carte de configuration existe.

   3

   Le nombre de partitions de sujets pour le courtier Kafka. Cela permet de contrôler la vitesse à laquelle les événements peuvent être envoyés au courtier. Un nombre plus élevé de partitions nécessite davantage de ressources informatiques.

   4

   Le facteur de réplication des messages thématiques. Cela permet d'éviter les pertes de données. Un facteur de réplication plus élevé nécessite davantage de ressources informatiques et de stockage.

   5

   Une liste de serveurs d'amorçage séparés par des virgules. Cela peut être à l'intérieur ou à l'extérieur du cluster OpenShift Container Platform, et c'est une liste de clusters Kafka que le courtier reçoit des événements de et envoie des événements à.

   Important

   La valeur default.topic.replication.factor doit être inférieure ou égale au nombre d'instances de courtiers Kafka dans votre cluster. Par exemple, si vous n'avez qu'un seul courtier Kafka, la valeur default.topic.replication.factor ne doit pas être supérieure à "1".

   Exemple de carte de configuration du courtier Kafka

   apiVersion: v1
   kind: ConfigMap
   metadata:
     name: kafka-broker-config
     namespace: knative-eventing
   data:
     default.topic.partitions: "10"
     default.topic.replication.factor: "3"
     bootstrap.servers: "my-cluster-kafka-bootstrap.kafka:9092"

2. Appliquer la carte de configuration :

   oc apply -f <config_map_filename> $ oc apply -f <config_map_filename>

3. Spécifiez la carte de configuration pour l'objet Kafka Broker:

   Exemple d'objet Broker

   apiVersion: eventing.knative.dev/v1
   kind: Broker
   metadata:
     name: <broker_name> 1
     namespace: <namespace> 2
     annotations:
       eventing.knative.dev/broker.class: Kafka 3
   spec:
     config:
       apiVersion: v1
       kind: ConfigMap
       name: <config_map_name> 4
       namespace: <namespace> 5
   ...

   1

   Le nom du courtier.

   2

   L'espace de noms dans lequel le courtier existe.

   3

   L'annotation de la classe du courtier. Dans cet exemple, le courtier est un courtier Kafka qui utilise la valeur de classe Kafka.

   4

   Le nom de la carte de configuration.

   5

   L'espace de noms dans lequel la carte de configuration existe.

4. Appliquer le courtier :

   oc apply -f <broker_filename>

Procédure

1. Créer ou modifier un objet Trigger et définir l'annotation kafka.eventing.knative.dev/delivery.order:

   apiVersion: eventing.knative.dev/v1
   kind: Trigger
   metadata:
     name: <trigger_name>
     annotations:
        kafka.eventing.knative.dev/delivery.order: ordered
   ...

   Les garanties de livraison aux consommateurs prises en charge sont les suivantes :

   unordered

   Un consommateur non ordonné est un consommateur non bloquant qui délivre des messages non ordonnés, tout en préservant une bonne gestion des décalages.

   ordered

   Un consommateur ordonné est un consommateur bloquant par partition qui attend une réponse positive de l'abonné CloudEvent avant de délivrer le message suivant de la partition.

   La garantie de commande par défaut est unordered.

2. Appliquer l'objet Trigger:

   $ oc apply -f <filename>