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 inserire il file scaricato in quella directory.

Kafka

Apri un Terminale facendo clic con il pulsante destro del mouse sulla cartella e facendo clic su Nuovo terminale nella 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 un 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/zookeeper-server-start.sh config/zookeeper.properties

Kafka

Vedrai questo:

Kafka

Tieni aperta questa finestra mentre stai attraversando questi esercizi!

Apri un altro, nuovo 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 un 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 per creare un nuovo argomento Kafka con il nome test positivo. 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 test positivo.

Kafka

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

Kafka

Invio Hello AEP again. e premi Invio.

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

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

Kafka

Sulla tastiera, fai clic su Control e C allo stesso tempo 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

Verranno quindi visualizzati tutti i messaggi prodotti nell'esercizio precedente per l'argomento test positivo, viene visualizzato nel consumer. Apache Kafka funziona così: un produttore crea eventi in una pipeline e un consumatore li consuma.

Kafka

Sulla tastiera, fai clic su Control e C allo stesso tempo 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