Etapa 2: Provisionar uma instância do Event Streams usando o console

1. Efetue login no console do IBM Cloud.

2. Clique no serviço Event Streams no Catálogo.

3. Selecione o Plano Lite, Plano Standard ou Plano Enterprise na seção Selecionar um plano de precificação.

4. Insira um nome para seu serviço. É possível usar o valor padrão.

5. Clique em Criar. A página Event Streams Lista de recursos é aberta.

6. Quando sua instância for criada, clique no nome da instância para visualizar mais informações.

7. Opcional. É possível concluir as etapas no tutorial Introdução para executar um app iniciador de amostra.

Etapa 2: Provisionar uma instância do Event Streams usando a CLI

Se essa for a primeira vez que você usa a CLI, consulte Introdução à CLI

Para provisionar uma instância do Event Streams Standard Plan com a CLI do IBM Cloud, conclua as etapas a seguir:

1. Instale a CLI do IBM Cloud concluindo as etapas em Introdução à IBM Cloud CLI.

2. Efetue login no IBM Cloud executando o comando a seguir:

   ibmcloud login -a cloud.ibm.com
   

3. Crie uma instância do Event Streams no IBM Cloud usando os planos Lite, Standard ou Enterprise.

   Selecione um dos métodos a seguir:

   • Para criar uma instância por meio da CLI no plano Enterprise, execute o seguinte comando:

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

     Como o plano Enterprise tem seus próprios recursos dedicados para cada cluster, ele requer mais tempo para provisionamento, portanto, uma nova instância Enterprise pode levar até 3 horas.

   • Para criar uma instância por meio da CLI no plano Standard, execute o seguinte comando:

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

     O provisionamento de uma nova instância do plano Standard é instantâneo porque os recursos subjacentes já estão configurados.

Etapa 2: Provisionar uma instância do Event Streams usando a API do controlador de recursos

O método preferencial para provisionar uma instância é usar a CLI.

Como alternativa, é possível usar a API do controlador de recurso Primeiro, recupere um token de acesso e, em seguida, execute um comando da API do controlador de recursos com o token de acesso para criar a instância

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"}}'

Etapa 3: Criar um tópico e selecionar o número de partições usando o console

Para obter orientação sobre as configurações que podem ser modificadas ao criar tópicos, consulte configuração de tópico

1. Em sua instância recém-provisionada, navegue para Tópicos usando o menu à esquerda.

2. Clique no botão Criar tópico e insira um nome de assunto. Clique em Avançar. Os nomes de tópicos estão restritos a um máximo de 200 caracteres.

3. Selecione o número de partições..

   Uma ou mais partições compõem um tópico. Uma partição é uma lista ordenada de mensagens.. 1 partição é suficiente para começar, mas os sistemas de produção geralmente têm mais.

   As partições são distribuídas entre os brokers para aumentar a escalabilidade do seu tópico. Também é possível usá-las para distribuir mensagens entre os membros de um grupo de consumidores.

   Clique em Avançar.

4. Defina o período de retenção de mensagens. Este é o tempo no qual as mensagens ficam retidas antes de serem excluídas. Se suas mensagens não forem lidas por um consumidor dentro deste tempo, elas serão perdidas. O período de retenção padrão das mensagens é de 24 horas. O mínimo é uma hora e o máximo é 30 dias. Especifique esse valor como múltiplos de horas.

   Clique em Criar tópico.

Etapa 3: Criar um tópico e selecionar o número de partições usando a CLI

Para obter orientação sobre as configurações que podem ser modificadas ao criar tópicos, consulte configuração de tópico

Use o seguinte comando ibmcloud es topic-create para criar um novo tópico com seu número escolhido de partições:

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

Pré-requisitos: nenhum

Opções de comando:

--name value, -n value

Nome do tópico. Os nomes de tópicos estão restritos a um máximo de 200 caracteres.

--partitions value, -p value

Configurar o número de partições para o tópico.

Uma ou mais partições compõem um tópico. Uma partição é uma lista ordenada de mensagens.. 1 partição é suficiente para começar, mas os sistemas de produção geralmente têm mais.

As partições são distribuídas entre os brokers para aumentar a escalabilidade do seu tópico. Também é possível usá-las para distribuir mensagens entre os membros de um grupo de consumidores.

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

Configurar uma opção de configuração para o tópico como um par KEY=VALUE.

É possível especificar várias opções --config. Cada opção '--config' pode especificar uma lista de designações delimitadas por ponto e vírgula. A lista a seguir mostra as chaves de configuração válidas:

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

O período de retenção padrão para mensagens conforme especificado pela chave retention.ms é de 24 horas. O mínimo é uma hora e o máximo é 30 dias. Especifique esse valor como múltiplos de horas.

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

ibmcloud es cluster [--json]

Etapa 3: Criar um tópico e selecionar o número de partições usando a API de REST do Administrador

Event Streams fornece uma API REST para administração que pode ser usada para criar e listar tópicos.

É possível criar um tópico Kafka emitindo uma solicitação POST no caminho /admin/topics. O corpo da solicitação deve conter um documento JSON Por exemplo:

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

O documento JSON deve conter um atributo name, especificando o nome do tópico Kafka a ser criado Os nomes de tópicos são restritos a um máximo de 200 characters.The também pode especificar o número de partições para designar ao tópico (usando a propriedade partitions ). Se o número de partições não for especificado, o tópico será criado com uma única partição.

Uma ou mais partições compõem um tópico. Uma partição é uma lista ordenada de mensagens.. 1 partição é suficiente para começar, mas os sistemas de produção geralmente têm mais.

As partições são distribuídas entre os brokers para aumentar a escalabilidade do seu tópico. Também é possível usá-las para distribuir mensagens entre os membros de um grupo de consumidores.

Também é possível especificar um objeto configs opcional dentro da solicitação Isso permite especificar a propriedade retentionMs, que controla por quanto tempo (em milissegundos) o Kafka retém mensagens publicadas no tópico. Após esse tempo, as mensagens são excluídas automaticamente para liberar espaço. Você deve especificar o valor da propriedade retentionMs em um número inteiro de horas (por exemplo, múltiplos de 3600000). O período de retenção padrão das mensagens é de 24 horas. O mínimo é uma hora e o máximo é 30 dias.

Para obter orientação sobre as configurações que podem ser modificadas ao criar tópicos, consulte configuração de tópico

Os códigos de status esperados para HTTP são os seguintes:

• 202: A solicitação de criação de tópico foi aceita
• 400: JSON de solicitação inválido
• 403: Não autorizado a criar o tópico
• 422: Solicitação emanticamente inválida.

Se a solicitação para criar um tópico Kafka for bem-sucedida, o código de status HTTP 202 (Aceito) será retornado. Se a operação falhar, um código de status HTTP de 422 (Entidade não processável) será retornado, e um objeto JSON contendo informações adicionais sobre a falha será retornado como o corpo da resposta.

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

Etapa 4 :Criar uma credencial de serviço usando o console.

Para permitir que você se conecte à instância do Event Streams, crie uma chave de serviço usando o console do IBM Cloud:

1. Localize seu serviço Event Streams na Lista de recursos.
2. Clique em seu bloco do serviço.
3. Clique em Credenciais de serviço.
4. Clique em Nova credencial.
5. Conclua os detalhes para a sua nova credencial como um nome e uma função e clique em Incluir. Uma nova credencialaparece na lista de credenciais.
6. Expanda a seção da nova credencial para revelar os detalhes no formato JSON

Etapa 4: criar uma credencial de serviço usando a CLI

Crie uma chave de serviço usando a CLI do IBM Cloud, para que seja possível se conectar à instância do Event Streams:

1. Localize seu serviço:

   ibmcloud resource service-instances
   

2. Crie uma chave de serviço:

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

3. Imprima a chave de serviço:

   ibmcloud resource service-key <key_name>
   

   Um único conjunto de detalhes do terminal está contido em cada chave de serviço. Para instâncias de serviço configuradas para serem conectadas a um único tipo de rede, a rede pública IBM Cloud (o padrão) ou a rede privada IBM Cloud, a chave de serviço contém os detalhes relevantes para esse tipo de rede. Para instâncias configuradas para suportar as redes privada e pública, são retornados detalhes para a rede pública. Se você desejar detalhes para a rede privada, deverá incluir o parâmetro --service-endpoint private no comando anterior da CLI service-key-create. Por exemplo:

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

Etapa 4: criar uma credencial de serviço usando a CLI e a API do produtor REST

Para se conectar à instância do Event Streams, o mecanismo de autenticação suportado está usando um token de acesso. Para obter seu token usando a CLI do IBM Cloud, primeiro faça login em IBM Cloud e, em seguida, execute o seguinte comando:

ibmcloud iam oauth-tokens

Coloque este token no cabeçalho de autorização da solicitação de HTTP no formulário Bearer<token>. A chave de API ou os tokens JWT são suportados.

Etapa 5: Produzir dados usando o console

Não é possível produzir dados usando o console.. É possível produzir dados usando a linha de comandos, a API do produtor REST ou a API doKafka.

No entanto, é possível concluir as etapas para o console no tutorial Introdução para executar um app iniciador de amostra e ver mensagens fluindo por meio de um tópico.

Etapa 5: Produzir dados usando a linha de comandos

É possível usar a ferramenta do produtor do console Event Streams Kafka para produzir dados. As ferramentas do console estão no diretório bin de seu download do cliente Kafka, que pode ser transferido por download a partir do downloads do Apache Kafka Recomendamos que você baixe a última versão binária estável disponível. As versões do cliente Kafka são compatíveis com a versão anterior do Kafka no servidor.

Deve-se fornecer uma lista de brokers (usando a propriedade BOOTSTRAP_ENDPOINTS) e credenciais SASL.

Para fornecer as credenciais SASL a essa ferramenta, crie um arquivo de propriedades com base no exemplo a seguir:

    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

Use o campo <user> da chave do serviço como o nome do usuário e o campo <api_key> da chave do serviço como a senha É possível localizar esses valores na guia Event Streams Credenciais de serviço no console do IBM Cloud.

O Event Streams fornece arquivos producer.properties e consumer.properties de exemplo para o Cliente Java

Depois de criar o arquivo de propriedades, você pode executar o produtor do console em um terminal da seguinte forma:

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

Substitua as variáveis a seguir no exemplo pelos seus próprios valores:

• BOOTSTRAP_ENDPOINTS com o valor de seu console do Event Streams Credenciais de serviço na IBM Cloud.
• CONFIG_FILE pelo caminho do arquivo de configuração.

• Use o campo <bootstrap_endpoints> da chave de serviço como a propriedade bootstrap.servers de seu aplicativo Kafka
• Use o campo <user> da chave do serviço como o nome do usuário e o campo <api_key> da chave do serviço como a senha Assegure-se de que seu aplicativo analise os detalhes.

Você pode usar muitas das outras opções dessa ferramenta, exceto aquelas que exigem acesso a ZooKeeper. Para obter mais informações, consulte Usando as ferramentas do console do Kafka com o Event Streams

Etapa 5: Produzir dados usando a API do Produtor REST

Use o ponto de extremidade v2 da API REST Producer para enviar mensagens do tipo text, binary, JSON ou avro para tópicos. Com o ponto de extremidade v2, você pode usar o registro de esquema Event Streams especificando o esquema para o tipo de dados avro.

• O que são cabeçalhos? Eles são opcionais? Você vê os cabeçalhos no corpo da mensagem Essa é a parte de dados que inclui tudo na solicitação ou resposta. Os cabeçalhos geralmente vêm após a linha de solicitação ou a linha de resposta O valor da cor é base64-como fazer isso?

O código a seguir mostra um exemplo de envio de uma mensagem do tipo text usando 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"

Para obter mais informações, consulte a Event Streams REST Producer v2 endpoint API reference.

Etapa 6: Consumir dados usando o console

Não é possível consumir dados usando o console.. É possível consumir dados usando a linha de comandos ou a API doKafka

No entanto, é possível concluir as etapas no tutorial Introdução para executar um app iniciador de amostra e ver mensagens fluindo por meio de um tópico.

Etapa 6: Consumir dados usando a linha de comandos

É possível usar a ferramenta do consumidor do console Event Streams Kafka para consumir dados.

As ferramentas do console estão no diretório bin de seu download do cliente Kafka

Deve-se fornecer uma lista de brokers e credenciais SASL. Depois de criar o arquivo de propriedades conforme descrito em produzir dados usando a linha de comandos, execute o consumidor do console em um terminal da seguinte forma:

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

Substitua as variáveis a seguir no exemplo pelos seus próprios valores:

• BOOTSTRAP_ENDPOINTS com o valor de seu console do Event Streams Credenciais de serviço na IBM Cloud.
• CONFIG_FILE pelo caminho do arquivo de configuração.

Você pode usar muitas das outras opções dessa ferramenta, exceto aquelas que exigem acesso a ZooKeeper. Para obter mais informações, consulte Usando as ferramentas do console do Kafka com o Event Streams

Etapa 6: Consumir dados usando uma API

Não é possível consumir dados usando uma API Event Streams, embora o consumo de dados do Kafka seja possível usando as bibliotecas nativas do Kafka. Para obter mais informações, consulte Kafka API do consumidor.

Como uma alternativa, use a linha de comandos

Etapa 7: Conectar IBM Cloud Monitoring para visibilidade operacional usando o console

É possível usar o IBM Cloud Monitoring para obter visibilidade operacional sobre o desempenho e o funcionamento de seus aplicativos, serviços e plataformas. O IBM Cloud Monitoring fornece administradores, equipes do DevOps e desenvolvedores de telemetria de pilha completa com recursos avançados para monitorar e solucionar problemas, definir alertas e projetar painéis customizados.

Para obter mais informações sobre como usar Monitoring com Event Streams, consulte:

• Optando por Métricas
• Ativando métricas padrão
• Ativando métricas aprimoradas
• Visualizando detalhes de métricas disponíveis
• Entendendo informações de custo de métricas

Etapa 7: Conecte IBM Cloud Monitoring para visibilidade operacional usando a CLI ou a linha de comandos

Não é possível conectar o IBM Cloud Monitoring usando a CLI ou a linha de comandos. Use o console para concluir esta tarefa

Etapa 7: conectar o IBM Cloud Monitoring para visibilidade operacional usando uma API

Não é possível conectar o IBM Cloud Monitoring usando uma API. Use o console para concluir esta tarefa

Etapa 8: Conectar o IBM Cloud® Activity Tracker à atividade de serviço de auditoria

O IBM Cloud Activity Tracker permite visualizar, gerenciar e auditar a atividade de serviço para estar em conformidade com as políticas corporativas e os regulamentos de mercado. Activity Tracker registra atividades iniciadas pelo usuário que mudam o estado de um serviço no IBM Cloud. Use o site Activity Tracker para rastrear como os usuários e aplicativos interagem com o serviço Event Streams nos planos Standard e Enterprise.

Para começar a usar o Activity Tracker, consulte Introdução ao Activity Tracker.

O Activity Tracker pode ter apenas uma instância por local. Para visualizar eventos, deve-se acessar a IU da web do serviço do Activity Tracker no mesmo local em que a sua instância de serviço estiver disponível. Para obter mais informações, consulte Ativar a IU da Web

Para obter mais informações sobre eventos específicos do Event Streams, consulte:

• Onde visualizar os eventos
• Eventos do tópico
• Eventos de auditoria de mensagem
• Outros eventos

Os eventos são formatados de acordo com o padrão CADF (Cloud Auditing Data Federation). Para obter detalhes adicionais sobre as informações que eles incluem, consulte Padrão CADF

Etapa 8: Conectar IBM Cloud® Activity Tracker usando a CLI ou a linha de comandos para auditar a atividade de serviço

Não é possível conectar o Activity Tracker usando a CLI ou a linha de comandos. Use o console para concluir esta tarefa

Etapa 8: Conectar o IBM Cloud® Activity Tracker usando uma API para auditar a atividade de serviço

Não é possível conectar o Activity Tracker usando uma API. Use o console para concluir esta tarefa