Passo 2: esegui il provisioning di un'istanza Event Streams utilizzando la console

1. Accedi alla console IBM Cloud.

2. Fare clic su Servizio Event Streams in Catalogo.

3. Seleziona il Piano Lite, il piano Standard o il piano Enterprise dalla sezione Seleziona un piano dei prezzi.

4. Immetti un nome per il tuo servizio. Puoi utilizzare il valore predefinito.

5. Fai clic su Crea. Viene aperta la pagina Event Streams Elenco risorse.

6. Una volta creata l'istanza, fare clic sul nome dell'istanza per visualizzare ulteriori informazioni.

7. Facoltativo. Puoi completare la procedura nell'Esercitazione introduttiva per eseguire un'applicazione starter di esempio.

Passo 2: esegui il provisioning di un'istanza Event Streams utilizzando la CLI

Se è la prima volta che utilizzi la CLI, vedi Introduzione alla CLI.

Per eseguire il provisioning di un'istanza del piano standard Event Streams con la CLI IBM Cloud, completa la seguente procedura:

1. Installa la CLI IBM Cloud completando i passi in Introduzione alla CLI IBM Cloud.

2. Accedi a IBM Cloud immettendo il seguente comando:

   ibmcloud login -a cloud.ibm.com
   

3. Crea un'istanza di Event Streams su IBM Cloud utilizzando i piani Lite, Standard o Enterprise.

   Seleziona uno dei seguenti metodi:

   • Per creare un'istanza dalla CLI sul piano Enterprise, eseguire il seguente comando:

     ibmcloud resource service-instance-create <INSTANCE_NAME> messagehub enterprise-3nodes-2tb <REGION>
     

     Poiché il piano Enterprise ha risorse dedicate per ogni cluster, richiede più tempo per l'approvvigionamento, quindi una nuova istanza Enterprise potrebbe richiedere fino a 3 ore.

   • Per creare un'istanza dalla CLI nel piano Standard, esegui questo comando:

     ibmcloud resource service-instance-create <INSTANCE_NAME> messagehub standard <REGION>
     

     L'approvvigionamento di una nuova istanza del piano Standard è istantaneo perché le risorse sottostanti sono già impostate.

Passo 2: esegui il provisioning di un'istanza Event Streams utilizzando l'API del controller delle risorse

Il metodo preferito per eseguire il provisioning di un'istanza è utilizzare la CLI.

In alternativa, puoi utilizzare l'API controller delle risorse. Per prima cosa, richiama un token di accesso quindi esegui un comando API del controller della risorsa con il token di accesso per creare l'istanza.

curl -X POST https://resource-controller.cloud.ibm.com/v2/resource_instances -H "Authorization: ${token}" -H "Content-Type: application/json" \
-d '{ "name": "JG-test-curl", "target": "us-south", "resource_group":"9eba3cff1b0540b9ab7fb93829911da0", "resource_plan_id": "ibm.message.hub.enterprise.3nodes.2tb", "parameters":{"service-endpoints":"public","throughput":"150"}}'

Passo 3: crea un argomento e seleziona il numero di partizioni utilizzando la console

Per istruzioni sulle impostazioni che è possibile modificare durante la creazione degli argomenti, consultare Configurazione degli argomenti.

1. Dalla tua istanza di cui è stato appena eseguito il provisioning, passa a Topics utilizzando il menu sulla sinistra.

2. Fare clic sul pulsante Crea argomento e immettere un nome di argomento. Fai clic su Next. I nomi degli argomenti sono limitati a un massimo di 200 caratteri.

3. Selezionare il numero di partizioni.

   Una o più partizioni costituiscono un argomento. Una partizione è un elenco ordinato di messaggi. 1 partizione è sufficiente per iniziare, ma i sistemi di produzione spesso ne hanno di più.

   Le partizioni sono distribuite tra i broker per aumentare la scalabilità dell'argomento. Possono essere usate anche per distribuire i messaggi tra i membri di un gruppo di consumer.

   Fai clic su Next.

4. Imposta il periodo di conservazione dei messaggi. Questo è il periodo di conservazione dei messaggi prima che vengano eliminati. Se i messaggi non vengono letti da un consumer entro questo tempo, saranno persi. Il periodo di conservazione predefinito per i messaggi è di 24 ore. Il minimo è 1 ora e il massimo è 30 giorni. Specifica questo valore come multipli di ore.

   Fare clic su Crea argomento.

Passo 3: crea un argomento e seleziona un numero di partizioni utilizzando la CLI

Per istruzioni sulle impostazioni che è possibile modificare durante la creazione degli argomenti, consultare Configurazione degli argomenti.

Utilizza il seguente comando ibmcloud es topic - create per creare un nuovo argomento con il tuo numero di partizioni scelto:

ibmcloud es topic-create [--name] TOPIC_NAME [--partitions PARTITIONS] [--config KEY=VALUE[;KEY=VALUE]* ]*

Prerequisiti: Nessuno

Opzioni comando:

--name value, -n value

Nome argomento. I nomi degli argomenti sono limitati a un massimo di 200 caratteri.

--partitions value, -p value

Imposta il numero di partizioni per l'argomento.

Una o più partizioni costituiscono un argomento. Una partizione è un elenco ordinato di messaggi. 1 partizione è sufficiente per iniziare, ma i sistemi di produzione spesso ne hanno di più.

Le partizioni sono distribuite tra i broker per aumentare la scalabilità dell'argomento. Possono essere usate anche per distribuire i messaggi tra i membri di un gruppo di consumer.

--config KEY=VALUE, -c KEY=VALUE (facoltativo)

Imposta un'opzione di configurazione per l'argomento come una coppia KEY=VALUE.

Puoi specificare più opzioni --config. Ogni opzione '--config' può specificare un elenco delimitato da punti e virgola di assegnazioni. Il seguente elenco mostra le chiavi di configurazione valide:

• cleanup.policy
• retention.ms
• retention.bytes
• segment.bytes
• segment.ms
• segment.index.bytes

Il periodo di conservazione predefinito per i messaggi come specificato dalla chiave retention.ms è 24 ore. Il minimo è 1 ora e il massimo è 30 giorni. Specifica questo valore come multipli di ore.

ibmcloud es topics [--filter FILTER] [--json]

ibmcloud es cluster [--json]

Passo 3: crea un topic e seleziona il numero di partizioni utilizzando l'API REST Admin

Event Streams fornisce un'API REST per la gestione che puoi utilizzare per creare ed elencare argomenti.

Puoi creare un argomento di Kafka immettendo una richiesta POST nel percorso /admin/topics. Il corpo della richiesta deve contenere un documento JSON. Ad esempio:

{
    "name": "topicname",
    "partitions": 1,
    "configs": {
        "retentionMs": 86400000,
        "cleanupPolicy": "delete"
    }
}

Il documento JSON deve contenere un attributo name, specificando il nome dell'argomento Kafka da creare. I nomi argomento sono limitati ad un massimo di 200 characters.The può anche specificare il numero di partizioni da assegnare all'argomento (utilizzando la proprietà partitions ). Se il numero di partizioni non è specificato, l'argomento viene creato con una singola partizione.

Una o più partizioni costituiscono un argomento. Una partizione è un elenco ordinato di messaggi. 1 partizione è sufficiente per iniziare, ma i sistemi di produzione spesso ne hanno di più.

Le partizioni sono distribuite tra i broker per aumentare la scalabilità dell'argomento. Possono essere usate anche per distribuire i messaggi tra i membri di un gruppo di consumer.

È inoltre possibile specificare un oggetto configs facoltativo all'interno della richiesta. Ciò consente di specificare la proprietà retentionMs, che controlla per quanto tempo (in millisecondi) Kafka conserva i messaggi pubblicati nell'argomento. Trascorso questo tempo, i messaggi vengono eliminati automaticamente per liberare spazio. È necessario specificare il valore della proprietà retentionMs in un numero intero di ore (ad esempio, multipli di 3600000). Il periodo di conservazione predefinito per i messaggi è di 24 ore. Il minimo è 1 ora e il massimo è 30 giorni.

Per istruzioni sulle impostazioni che è possibile modificare durante la creazione degli argomenti, consultare Configurazione degli argomenti.

I codici di stato dell' HTTP e previsti sono i seguenti:

• 202: La richiesta di creazione dell'argomento è stata accettata.
• 400: JSON richiesta non valida.
• 403: Non autorizzato a creare l'argomento.
• 422: Richiesta semanticamente non valida.

Se la richiesta di creare un argomento di discussione ( Kafka ) va a buon fine, viene restituito un codice di stato 202 (Accettato) ( HTTP ). Se l'operazione non riesce, viene restituito un codice di stato HTTP e 422 (entità non elaborabile) e un oggetto JSON contenente ulteriori informazioni sull'errore viene restituito come corpo della risposta.

curl -i -X POST -H 'Accept: application/json' -H 'Content-Type: application/json' -H 'Authorization: Bearer ${TOKEN}' --data '{ "name": "newtopic", "partitions": 1}' ${ADMIN_URL}/admin/topics

[
  {
    "name": "topic1",
    "partitions": 1,
    "retentionMs": 86400000,
    "cleanupPolicy": "delete"
  },
  { "name": "topic2",
    "partitions": 2,
    "retentionMs": 86400000,
    "cleanupPolicy": "delete"
  }
]

curl -i -X GET -H 'Accept: application/json' -H 'Authorization: Bearer ${TOKEN}' ${ADMIN_URL}/admin/topics

Passo 4: crea una credenziale del servizio utilizzando la console

Per consentirti di connetterti alla tua istanza Event Streams, crea una chiave del servizio utilizzando la console IBM Cloud:

1. Individua il tuo servizio Event Streams nell'Elenco risorse.
2. Fai clic sul tuo tile del servizio.
3. Fai clic su Credenziali del servizio.
4. Fai clic su New credential.
5. Completa i dettagli per la tua nuova credenziale, come ad esempio un nome e un ruolo, e fai clic su Aggiungi. Viene visualizzata una nuova credenziale nell'elenco delle credenziali.
6. Espandere la nuova sezione delle credenziali per rivelare i dettagli in formato JSON.

Passo 4: crea una credenziale del servizio utilizzando la CLI

Crea una chiave del servizio utilizzando la CLI IBM Cloud, in modo da poterti connettere alla tua istanza Event Streams:

1. Individua il tuo servizio:

   ibmcloud resource service-instances
   

2. Crea una chiave di servizio:

   ibmcloud resource service-key-create <key_name> <key_role> --instance-name <your_service_name>
   

3. Stampa la chiave di servizio:

   ibmcloud resource service-key <key_name>
   

   Una singola serie di dettagli dell'endpoint è contenuta in ciascuna chiave di servizio. Per le istanze del servizio configurate per essere connesse a un singolo tipo di rete, la rete pubblica IBM Cloud (impostazione predefinita) o la rete privata IBM Cloud, la chiave del servizio contiene i dettagli relativi a tale tipo di rete. Per le istanze configurate per supportare sia le reti private che pubbliche, vengono restituiti i dettagli per la rete pubblica. Se vuoi i dettagli per la rete privata, devi aggiungere il parametro --service-endpoint private al precedente comando CLI service - key - create. Ad esempio:

   ibmcloud resource service-key-create <private-key-name> <role> --instance-name <instance-name> --service-endpoint private
   

Passo 4: crea una credenziale del servizio utilizzando la CLI e l'API del produttore REST

Per connetterti alla tua istanza Event Streams, il meccanismo di autenticazione supportato utilizza un token di connessione. Per ottenere il tuo token utilizzando la CLI IBM Cloud, accedi prima a IBM Cloud ed esegui quindi il seguente comando:

ibmcloud iam oauth-tokens

Inserire questo token nell'intestazione dell'autorizzazione della richiesta HTTP nel formato Bearer<token>. Sono supportati sia la chiave API che i token JWT.

Passo 5: Produce i dati utilizzando la console

Non è possibile produrre dati utilizzando la console. Puoi produrre i dati utilizzando la riga di comando, l'API REST Producer o l'API Kafka.

Tuttavia, puoi completare la procedura per la console nell'Esercitazione introduttiva per eseguire un'applicazione starter di esempio e visualizzare i messaggi che passano attraverso un argomento.

Passo 5: produrre i dati utilizzando la linea di comando

Puoi usare lo strumento produttore della console Kafka Event Streams per produrre i dati. Gli strumenti della console si trovano nella directory bin del download del client Kafka, che puoi scaricare da Apache Kafka downloads. Si consiglia di scaricare l'ultima versione binaria stabile disponibile. Le versioni client Kafka sono retrocompatibili con la versione di Kafka sul server.

È necessario fornire un elenco di broker (utilizzando la proprietà BOOTSTRAP_ENDPOINTS) e credenziali SASL.

Per fornire le credenziali SASL a questo strumento, creare un file delle proprietà basato sul seguente esempio:

    sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<user>" password="<api_key>";
    security.protocol=SASL_SSL
    sasl.mechanism=PLAIN
    ssl.protocol=TLSv1.2
    ssl.enabled.protocols=TLSv1.2
    ssl.endpoint.identification.algorithm=HTTPS

Utilizza il campo <user> dalla chiave del servizio come nome utente e il campo <api_key> dalla chiave del servizio come password. Puoi trovare questi valori nella scheda Event Streams Service Credentials nella console di IBM Cloud.

Event Streams fornisce file di esempio producer.properties e consumer.properties per il client Java.

Dopo aver creato il file delle proprietà, è possibile eseguire il produttore della console in un terminale come segue:

   kafka-console-producer.sh --broker-list BOOTSTRAP_ENDPOINTS --producer.config CONFIG_FILE --topic TOPIC_NAME

Sostituisci le seguenti variabili nell'esempio con i tuoi propri valori:

• BOOTSTRAP_ENDPOINTS con il valore dalla scheda Event Streams Service Credentials della console IBM Cloud.
• CONFIG_FILE con il percorso del file di configurazione.

• Utilizza il campo <bootstrap_endpoints> dalla chiave del servizio come proprietà bootstrap.servers della tua applicazione Kafka.
• Utilizza il campo <user> dalla chiave del servizio come nome utente e il campo <api_key> dalla chiave del servizio come password. Assicurati che la tua applicazione analizzi i dettagli.

È possibile utilizzare molte altre opzioni di questo strumento, ad eccezione di quelle che richiedono l'accesso a ZooKeeper. Per ulteriori informazioni, vedi Utilizzo degli strumenti della console Kafka con Event Streams.

Passo 5: produrre i dati utilizzando l'API Producer REST

Utilizzare l'endpoint v2 dell'API REST Producer per inviare messaggi di tipo text, binary, JSON o avro agli argomenti. Con l'endpoint v2 è possibile utilizzare il registro di schemi Event Streams specificando lo schema per il tipo di dati avro.

• Cosa sono le intestazioni? Sono facoltativi? Vengono visualizzate le intestazioni nel corpo del messaggio. Questa è la porzione di dati che include tutto nella richiesta o nella risposta. Le intestazioni generalmente vengono dopo la riga di richiesta o la riga di risposta. Il valore del colore è base64- come fare?

Il codice seguente mostra un esempio di invio di un messaggio di tipo text utilizzando curl:

curl -v -X POST \
-H "Authorization: Bearer $token" -H "Content-Type: application/json" -H "Accept: application/json" \
-d '{
  "headers": [
    {
      "name": "colour",
      "value": "YmxhY2s="
    }
  ],
  "key": {
    "type": "text",
    "data": "Test Key"
  },
  "value": {
    "type": "text",
    "data": "Test Value"
  }
}' \
"$kafka_http_url/v2/topics/$topic_name/records"

Per ulteriori informazioni, vedi il Riferimento API endpointEvent Streams REST Producer v2.

Passo 6: utilizza i dati utilizzando la console

Non è possibile utilizzare i dati utilizzando la console. Puoi utilizzare i dati utilizzando la riga di comando o l'APIKafka.

Tuttavia, puoi completare la procedura nell'Esercitazione introduttiva per eseguire un'applicazione starter di esempio e visualizzare i messaggi che passano attraverso un argomento.

Passo 6: utilizza i dati utilizzando la riga di comando

Per utilizzare i dati, puoi utilizzare lo strumento consumer della console Kafka Event Streams.

Gli strumenti della console si trovano nella directory bin del download del client Kafka.

Devi fornire un elenco di broker e le credenziali SASL. Dopo aver creato il file delle proprietà come descritto in produrre i dati utilizzando la riga comandi, eseguire il consumer della console in un terminale nel modo seguente:

   kafka-console-consumer.sh --bootstrap-server BOOTSTRAP_ENDPOINTS --consumer.config CONFIG_FILE --topic TOPIC_NAME

Sostituisci le seguenti variabili nell'esempio con i tuoi propri valori:

• BOOTSTRAP_ENDPOINTS con il valore dalla scheda Event Streams Service Credentials della console IBM Cloud.
• CONFIG_FILE con il percorso del file di configurazione.

È possibile utilizzare molte altre opzioni di questo strumento, ad eccezione di quelle che richiedono l'accesso a ZooKeeper. Per ulteriori informazioni, vedi Utilizzo degli strumenti della console Kafka con Event Streams.

Passo 6: utilizza i dati utilizzando un'API

Non puoi utilizzare i dati utilizzando un'API Event Streams anche se il consumo di dati da Kafka è possibile utilizzando le librerie Kafka native. Per ulteriori informazioni, consulta Kafka consumer API.

In alternativa, utilizzare la riga comandi.

Passo 7: Connetti IBM Cloud Monitoring per la visibilità operativa utilizzando la console

Puoi utilizzare IBM Cloud Monitoring per ottenere la visibilità operativa delle prestazioni e dell'integrità di applicazioni, servizi e piattaforme. IBM Cloud Monitoring fornisce agli amministratori, ai team DevOps e agli sviluppatori la telemetria a stack completo con funzioni avanzate per monitorare e risolvere i problemi, definire avvisi e progettare dashboard personalizzati.

Per ulteriori informazioni su come utilizzare Monitoring con Event Streams, vedi:

• Opting in to metrics
• Abilitazione delle metriche predefinite
• Abilitazione delle metriche avanzate
• Visualizzazione dei dettagli delle metriche disponibili
• Informazioni sui costi delle metriche

Passo 7: Connetti IBM Cloud Monitoring per la visibilità operativa utilizzando la CLI o la riga di comando

Non puoi connettere IBM Cloud Monitoring utilizzando la CLI o la riga di comando. Utilizzare la console per completare questa attività.

Passo 7: connetti IBM Cloud Monitoring per la visibilità operativa utilizzando un'API

Non puoi connettere IBM Cloud Monitoring utilizzando un'API. Utilizzare la console per completare questa attività.

Passo 8: connetti IBM Cloud® Activity Tracker all'attività del servizio di verifica

IBM Cloud Activity Tracker ti consente di visualizzare, gestire e controllare l'attività del servizio per rispettare le politiche aziendali e le normative di settore. Activity Tracker registra attività avviate dall'utente che modificano lo stato di un servizio in IBM Cloud. Utilizza Activity Tracker per monitorare come gli utenti e le applicazioni interagiscono con il servizio Event Streams nei piani Standard ed Enterprise.

Per essere attivo e in esecuzione con Activity Tracker, vedi Introduzione a Activity Tracker.

Activity Tracker può avere solo un'istanza per ubicazione. Per visualizzare gli eventi, devi accedere alla IU web del servizio Activity Tracker nella stessa ubicazione in cui è disponibile la tua istanza del servizio. Per ulteriori informazioni, consulta Avvia l'IU web.

Per ulteriori informazioni sugli eventi specifici di Event Streams, vedi:

• Dove visualizzare gli eventi
• Eventi argomenti
• Eventi di controllo messaggi
• Altri eventi

Gli eventi sono formattati secondo lo standard Cloud Auditing Data Federation (CADF). Per ulteriori dettagli sulle informazioni che includono, consultare Standard CADF.

Passo 8: collega IBM Cloud® Activity Tracker utilizzando la CLI o la riga di comando per controllare l'attività del servizio

Non puoi connettere Activity Tracker utilizzando la CLI o la riga di comando. Utilizzare la console per completare questa attività.

Passo 8: connetti IBM Cloud® Activity Tracker utilizzando un'API per controllare l'attività del servizio

Non puoi connettere Activity Tracker utilizzando un'API. Utilizzare la console per completare questa attività.