24.2 Installare e configurare il cluster Kafka

24.2.1 Scarica Apache Kafka

Vai a https://kafka.apache.org/downloads e scarica l'ultima versione rilasciata. Seleziona la versione binaria più recente, in questo caso Scala 2.13.

Kafka

Poi vieni portato in un sito mirror. Fai clic sul link suggerito per scaricare Kafka.

Kafka

Crea una cartella sul desktop denominata Kafka_AEP e inserisci il file scaricato in tale directory.

Kafka

Apri una finestra Terminale facendo clic con il pulsante destro del mouse sulla cartella e scegliendo Nuovo terminale in Cartella.

Kafka

Esegui questo comando nella finestra Terminal per decomprimere il file scaricato:

tar -xvf kafka_2.13-2.8.0.tgz

Kafka

Vedrai questo:

Kafka

Dopo aver decompresso quel file, ora avete una directory come questa:

Kafka

E in quella directory, vedrete questi sottodirectory:

Kafka

Torna alla finestra Terminal. Immetti il seguente comando:

cd kafka_2.13-2.8.0

Kafka

Quindi, immetti il comando bin/kafka-topics.sh.

Kafka

Dovresti quindi visualizzare questa risposta. Ciò significa che Kafka è installato correttamente e che Java sta funzionando bene. (Promemoria: hai bisogno di Java 8 JDK o Java 11 JDK installato perché questo funzioni!. Puoi vedere quale versione Java hai installato utilizzando il comando java -version.)

Kafka

24.2.2 Avvia Kafka

Per iniziare Kafka, avrai bisogno di avviare Kafka Zookeeper e Kafka, in questo ordine.

Apri una finestra Terminal facendo clic con il pulsante destro del mouse sulla cartella kafka_2.13-2.8.0 e facendo clic su Nuovo terminale a cartella.

Kafka

Inserisci questo comando:

bin/zookeeper-server-start.sh config/zookeeper.properties

Kafka

Vedrai questo:

Kafka

Tieni aperta questa finestra mentre stai attraversando questi esercizi!

Apri un'altra nuova finestra Terminale facendo clic con il pulsante destro del mouse sulla cartella kafka_2.13-2.8.0 e facendo clic su Nuovo terminale nella cartella.

Kafka

Inserisci questo comando:

bin/kafka-server-start.sh config/server.properties

Kafka

Vedrai questo:

Kafka

Tieni aperta questa finestra mentre stai attraversando questi esercizi!

24.2.3 Creare un argomento Kafka

Apri una finestra Terminal facendo clic con il pulsante destro del mouse sulla cartella kafka_2.13-2.8.0 e facendo clic su Nuovo terminale a cartella.

Kafka

Inserisci questo comando per creare un nuovo argomento Kafka con il nome aeptest. Questo argomento verrà utilizzato per il test in questo esercizio.

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic aeptest --create --partitions 1 --replication-factor 1

Kafka

Verrà visualizzata una conferma simile:

Kafka

Inserisci questo comando per creare un nuovo argomento Kafka con il nome aep. Questo argomento verrà utilizzato da Adobe Experience Platform Sink Connector che verrà configurato negli esercizi successivi.

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic aep --create --partitions 1 --replication-factor 1

Kafka

Verrà visualizzata una conferma simile:

Kafka

24.2.4 Eventi di produzione

Torna alla finestra Terminal in cui hai creato il tuo primo argomento Kafka e immetti il seguente comando:

bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic aeptest

Kafka

Vedrete questo. A ogni nuova riga seguita da un pulsante Invio viene inviato un nuovo messaggio nell'argomento aeptest.

Kafka

Inserisci Hello AEP e premi Invio. Il tuo primo evento è stato inviato nell'istanza Kafka locale, nell'argomento aeptest.

Kafka

Inserisci Hello AEP again. e premi Invio.

Inserisci AEP Data Collection is the best. e premi Invio.

Ora hai prodotto 3 eventi nell'argomento aeptest. Questi eventi possono ora essere utilizzati da un'applicazione che potrebbe necessitare di tali dati.

Kafka

Sulla tastiera, fare clic contemporaneamente su Control e C per chiudere il produttore.

Kafka

24.2.4 Eventi di consumo

Nella stessa finestra Terminal utilizzata per generare eventi, immettere il comando seguente:

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic aeptest --from-beginning

Vedrai tutti i messaggi prodotti nell'esercizio precedente per l'argomento aeptest, visualizzati nel consumatore. Apache Kafka funziona così: un produttore crea eventi in una pipeline e un consumatore li consuma.

Kafka

Sulla tastiera, fare clic contemporaneamente su Control e C per chiudere il produttore.

Kafka

In questo esercizio, hai esaminato tutte le nozioni di base per configurare un cluster Kafka locale, creare un argomento Kafka, produrre eventi e consumare eventi.

L'obiettivo di questo modulo è quello di simulare cosa succederebbe se una vera organizzazione avesse già implementato un cluster Apache Kafka, e volesse trasmettere dati dal proprio cluster Kafka a Adobe Experience Platform.

Per facilitare tale implementazione, è stato creato un connettore Adobe Experience Platform Sink che può essere implementato utilizzando Kafka Connect. È possibile trovare la documentazione di quel connettore Sink Adobe Experience Platform qui: https://github.com/adobe/experience-platform-streaming-connect.

Negli esercizi successivi, implementerai tutto il necessario per utilizzare il connettore Sink Adobe Experience Platform dall'interno del tuo cluster Kafka locale.

Chiudi la finestra del terminale.

Ha finito questo esercizio.

Passaggio successivo: 24.3 Configurare l'endpoint API HTTP in Adobe Experience Platform

Torna al modulo 24

Torna a tutti i moduli

In questa pagina