Testnachrichten aus einem Hermes -Thema mit dem Kafka-Client verbrauchen

Freigeben Version: Xanadu

Aktualisiert 1. August 2024

2 Minuten Lesedauer

Testnachrichten aus einem Hermes -Thema durch Konfiguration von zwei Verbraucher-Clients verbrauchen.

Vorbereitungen

Sichern Sie Ihre Kafka-Themen, indem Sie ein von der Instanz ServiceNow® signiertes Zertifikat und einen Schlüsselspeicher generieren. Sie müssen Truststore- und Schlüsselspeicherdetails angeben, wenn Sie die Hermes -Verbraucher konfigurieren. Weitere Informationen finden Sie unter Richten Sie eine sichere Verbindung zum ein Hermes Messaging-Service.
Laden Sie Apache Kafkaherunter, und installieren Sie es. Weitere Informationen finden Sie unter Bereiten Sie Ihre Apache Kafka -Client-Umgebung vor.
Erstellen Sie ein Thema, und erzeugen Sie Testnachrichten im Kafka-Cluster Hermes, bevor Sie Nachrichten verbrauchen können. Details finden Sie unter Erstellen Sie mit dem Kafka-Client ein Testthema in Hermes . und Mit dem Kafka-Client Testnachrichten an ein Thema Hermes erstellen.

Erforderliche Rolle: admin

Warum und wann dieser Vorgang ausgeführt wird

In den folgenden Schritten wird beschrieben, wie Sie zwei Verbraucherclients konfigurieren und Testnachrichten vom Kafka-Cluster Hermes empfangen. Da Hermes ein Paar Kafka-Cluster verwendet, müssen Sie zwei Verbraucher-Clients mit separaten Verbraucher-Bootstrap-Adressen konfigurieren.

Wichtig:

Sie müssen zwei unterschiedliche Bootstrap-Adressen für Verbraucher konfigurieren, eine für jeden Verbraucher-Client.

Befolgen Sie diese Schritte, wenn Sie bereit sind, Nachrichten von Hermes für Geschäfts- oder Produktionszwecke zu verwenden.

Prozedur

Navigieren Sie zu dem Konfigurationsverzeichnis, in das Sie Kafka extrahiert haben.
- Beispiel unter Unix:
```
cd /home/user/Software/kafka/config
```
- Beispiel unter Windows:
```
cd C:\Software\kafka\config
```
Konfigurieren Sie die Verbraucher.
1. Öffnen Sie die Datei „ consumer.properties “.
2. Konfigurieren Sie die folgenden SSL-Eigenschaften:
```
security.protocol=SSL

ssl.truststore.password=<truststore password>

ssl.truststore.location=<path to truststore.p12>

ssl.truststore.type=PKCS12

ssl.keystore.password=<keystore password>

ssl.keystore.location=<path to keystore.p12>

ssl.keystore.type=PKCS12

ssl.key.password=<keystore password>
```
  Ersetzen Sie die folgenden Platzhaltervariablen:
  - <truststore password>mit Ihrem Truststore-Passwort
  - <path to truststore.p12>mit dem Pfad zu Ihrer Truststore-Datei
  - <keystore password>mit Ihrem Schlüsselspeicher-Passwort
  - <path to keystore.p12>mit dem Pfad zu Ihrer Schlüsselspeicherdatei
3. Speichern Sie Ihre Änderungen im Nur-Text-Format.

Verbrauchen Sie eine Nachricht für jeden Verbraucher.

Führen Sie den folgenden Befehl für den ersten Verbraucherclient aus:

Unix:

./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103

Windows:

bin/windows/kafka-console-consumer.bat --consumer.config config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103

Ersetzen Sie die folgenden Platzhaltervariablen:

<instance_name>mit dem Instanznamen
<namespace>durch den Namespace der Domäne, zu der Ihr Kafka-Thema gehört (optional)
<app_id>mit der Anwendungs-ID
<topic_name>mit einem Testthemennamen
<consumer_group_id>mit einer Bezeichnung Ihrer Wahl für die Gruppe, zu der der Verbraucher gehört

Hinweis:

Bei jedem Teil des Themennamens wird zwischen Groß- und Kleinschreibung unterschieden.

Öffnen Sie ein neues Terminalfenster.
Navigieren Sie zum Kafka-Verzeichnis.

Führen Sie den folgenden Befehl für den zweiten Verbraucherclient aus:

Unix:

./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203

Windows:

bin/windows/kafka-console-consumer.bat --consumer.config config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203

Ersetzen Sie die folgenden Platzhaltervariablen:

<instance_name>mit dem Instanznamen
<namespace>durch den Namespace der Domäne, zu der Ihr Kafka-Thema gehört (optional)
<topic_name>mit einem Testthemennamen
<consumer_group_id>mit einer Bezeichnung Ihrer Wahl für die Gruppe, zu der der Verbraucher gehört

Hinweis:

Bei jedem Teil des Themennamens wird zwischen Groß- und Kleinschreibung unterschieden.

Ergebnisse

Testnachrichten werden vom Kafka-Cluster Hermes konsumiert.