Schritt 3: Client-Computer und Apache-Kafka-Thema erstellen

In diesem Schritt erstellen Sie eine Amazon-EC2-Instance, die als Apache-Kafka-Client-Instance verwendet werden soll. Anschließend verwenden Sie diese Instance, um ein Thema im Cluster zu erstellen.

Erstellen eines Client-Computers

1. Öffnen Sie die Amazon EC2-Konsole unter https://console.aws.amazon.com/ec2/.

2. Wählen Sie Launch Instances aus.

3. Geben Sie einen Namen für Ihren Client-Computer ein, z. B. mkc-tutorial-client

4. Lassen Sie Amazon Linux 2 AMI (HVM) – Kernel 5.10, SSD Volume Type als Amazon Machine Image (AMI)-Typ ausgewählt.

5. Wählen Sie den Instance-Typ t2.xlarge.

6. Wählen Sie unter Schlüsselpaar (Login) die Option Neues Schlüsselpaar erstellen. Geben Sie mkc-tutorial-key-pair für den Schlüsselpaar-Namen ein und wählen Sie dann Schlüsselpaar herunterladen. Alternativ können Sie ein vorhandenes Schlüsselpaar verwenden.

7. Wählen Sie Launch Instance (Instance starten) aus.

8. Klicken Sie auf View Instances (Instances anzeigen). Wählen Sie dann in der Spalte Sicherheitsgruppen die Sicherheitsgruppe, die Ihrer neuen Instance zugeordnet ist. Kopieren Sie die ID der Sicherheitsgruppe, und speichern Sie sie für später.

So erlauben Sie es dem neu erstellten Client, Daten an den Cluster zu senden

1. Öffnen Sie die Amazon VPC-Konsole unter https://console.aws.amazon.com/vpc/.

2. Wählen Sie im linken Bereich unter SECURITY die Option Sicherheitsgruppen. Suchen Sie in der Spalte Sicherheitsgruppen-ID die Sicherheitsgruppe des Clusters. Sie haben die ID dieser Sicherheitsgruppe gespeichert, als Sie den Cluster in Schritt 1: Die erforderlichen Ressourcen einrichten erstellt haben. Wählen Sie diese Sicherheitsgruppe aus, indem Sie das Feld links neben der Zeile auswählen. Stellen Sie sicher, dass keine anderen Sicherheitsgruppen gleichzeitig ausgewählt sind.

3. Wählen Sie im unteren Bereich der Seite die Registerkarte Regeln für eingehenden Datenverkehr.

4. Wählen Sie Edit inbound rules (Regeln für eingehenden Datenverkehr bearbeiten) aus.

5. Wählen Sie unten links auf dem Bildschirm Regel hinzufügen.

6. Wählen Sie in der neuen Regel All traffic (Gesamter Datenverkehr) in der Spalte Type (Typ). Geben Sie im Feld rechts neben der Spalte Quelle die ID der Sicherheitsgruppe des Client-Computers ein. Dies ist die Sicherheitsgruppen-ID, die Sie gespeichert haben, nachdem Sie den Client-Computer erstellt haben.

7. Wählen Sie Save rules (Regeln speichern) aus. Ihr MSK-Cluster akzeptiert jetzt den gesamten Datenverkehr von dem Client, den Sie im vorherigen Verfahren erstellt haben.

Erstellen Sie ein Thema wie folgt

1. Öffnen Sie die Amazon EC2-Konsole unter https://console.aws.amazon.com/ec2/.

2. Wählen Sie mkc-tutorial-client in der Instance-Tabelle.

3. Wählen Sie oben auf dem Bildschirm Verbinden aus und folgen Sie dann den Anweisungen, um eine Verbindung mit der Instance herzustellen.

4. Installieren Sie Java auf der Client-Instance, indem Sie den folgenden Befehl ausführen:

   sudo yum install java-1.8.0

5. Führen Sie den folgenden Befehl aus, um Apache Kafka herunterzuladen.

   wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz

   Anmerkung

   Wenn Sie eine andere als die in diesem Befehl verwendete Spiegelsite verwenden möchten, können Sie eine andere auf der Apache-Website auswählen.

6. Führen Sie den folgenden Befehl in dem Verzeichnis aus, in das Sie im vorherigen Schritt die TAR-Datei heruntergeladen haben.

   tar -xzf kafka_2.12-2.2.1.tgz

7. Wechseln Sie zum Verzeichnis kafka_2.12-2.2.1.

8. Öffnen Sie die Amazon-MSK-Konsole unter https://console.aws.amazon.com/msk/home?region=us-east-1#/home/.

9. Wählen Sie im linken Bereich Cluster und dann den Namen mkc-tutorial-cluster.

10. Wählen Sie Client-Informationen anzeigen aus.

11. Kopieren Sie die Klartext-Verbindungszeichenfolge.

12. Wählen Sie Erledigt aus.

13. Führen Sie den folgenden Befehl auf der Client-Instanz (mkc-tutorial-client) aus und bootstrapServerStringersetzen Sie ihn durch den Wert, den Sie gespeichert haben, als Sie sich die Client-Informationen des Clusters angesehen haben.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server bootstrapServerString --replication-factor 2 --partitions 1 --topic mkc-tutorial-topic

    Wenn der Befehl erfolgreich ist, wird die folgende Meldung angezeigt: Created topic mkc-tutorial-topic.

Nächster Schritt

Schritt 4: Konnektor erstellen