Crear un pool de flujos

Cree un pool de flujos en el servicio Streaming. Un pool de flujos es una agrupación lógica para flujos.

Cada flujo debe ser miembro de un pool de flujos. Si no crea un pool de flujos o especifica un pool de flujos existente al crear un flujo, el servicio Streaming utiliza un pool por defecto para contener el flujo. Para revisar los requisitos para crear y gestionar flujos, consulte Introducción a Streaming.

    1. En la página de lista Pools de flujos, seleccione Crear pool de flujos. Si necesita ayuda para buscar la página de lista, consulte Listado de pools de flujos.
    2. Introduzca un nombre para el pool de flujos. Evite introducir información confidencial.
    3. Seleccione el compartimento para el pool de flujos.
    4. Seleccionar tipo de punto final. Seleccione Punto Final Público o Punto Final Privado, en función de si desea restringir el tráfico a los flujos de este pool de flujos a un punto final privado que no requiera que el tráfico pase por Internet.

      Para crear un punto final privado, necesita acceso a una red virtual en la nube (VCN) con una subred privada. Seleccione una VCN con una subred privada en la que también esté activada la resolución DNS y, a continuación, seleccione la subred.

      Si, en su lugar, desea asignar una dirección IP privada específica, debe seleccionar una que pertenezca al CIDR de la subred. Por defecto, el servicio de redes asigna una dirección IP privada aleatoria en su nombre y no aplica reglas de seguridad al pool de flujos. Para obtener más información, consulte Gestión de subredes y VCN.

      También puede seleccionar un grupo de seguridad de red existente para aplicar el mismo conjunto de reglas de seguridad a cada flujo del pool.

    5. En Configurar valores de cifrado, seleccione cómo cifrar los flujos en el pool de flujos.

      Por defecto, se selecciona Cifrar utilizando claves gestionadas por Oracle. Para cifrar los datos de los flujos de este pool de flujos mediante su propia clave de cifrado de Vault, seleccione Cifrar mediante claves gestionadas por el cliente. Para utilizar el servicio Vault, necesita tener acceso a un almacén y a una clave, y debe permitir que el servicio utilice la clave.

      • Almacén: seleccione el almacén que contiene la clave de cifrado maestra que desea utilizar.
      • clave de cifrado maestra: seleccione la clave de cifrado maestra que desea utilizar.

      Para obtener más información sobre el cifrado con una clave de Almacén que gestione, consulte Visión general de Vault y Gestión de claves.

    6. Para agregar etiquetas o si desea utilizar Kafka con este pool de flujos, seleccione Mostrar opciones avanzadas.
    7. (Opcional) Asigne etiquetas al pool de flujos. Si tiene permisos para crear un recurso, también los tiene para aplicar etiquetas de formato libre a ese recurso. Para aplicar una etiqueta definida, debe tener permisos para utilizar el espacio de nombres de la etiqueta. Para obtener más información sobre el etiquetado, consulte Etiquetas de recursos. Si no está seguro de si aplicar etiquetas, omita esta opción o pregunte a un administrador. Puede aplicar etiquetas más tarde.
    8. Para utilizar el pool de flujos con Kafka, seleccione Crear temas automáticamente y configure los valores de flujo:
      • Período de retención por defecto (horas): especifique el número de horas para el período de retención del flujo.
      • Número por defecto de particiones: especifique el número por defecto de particiones para el flujo.
      • Seleccione Ver la configuración de Kafka después de crear el pool de flujos para mostrar la configuración de conexión de Kafka para el pool de flujos después de su creación.
    9. (Opcional) Agregue una o más etiquetas al pool de flujos: seleccione Mostrar opciones avanzadas para mostrar la sección Agregar etiquetas.
      Si tiene permisos para crear un recurso, también los tiene para aplicar etiquetas de formato libre a ese recurso. Para aplicar una etiqueta definida, debe tener permisos para utilizar el espacio de nombres de la etiqueta. Para obtener más información sobre el etiquetado, consulte Etiquetas de recursos. Si no está seguro de si aplicar etiquetas, omita esta opción o pregunte a un administrador. Puede aplicar etiquetas más tarde.
    10. Haga clic en Crear.
  • Utilice el comando oci streaming admin stream-pool create y los parámetros necesarios para crear un pool de flujos:

    oci streaming admin stream-pool create --name <stream_pool_name> --compartment-id <compartment_OCID>

    Por ejemplo:

    oci streaming admin stream-pool create --name MyStreamPool --compartment-id ocid1.tenancy.oc1..exampleuniqueID
    {
      "data": {
        "compartment-id": "ocid1.tenancy.oc1..exampleuniqueID",
        "custom-encryption-key": {
          "key-state": "NONE",
          "kms-key-id": null
        },
        "defined-tags": {},
        "endpoint-fqdn": null,
        "freeform-tags": {},
        "id": "ocid1.streampool.oc1.phx.exampleuniqueID",
        "is-private": false,
        "kafka-settings": {
          "auto-create-topics-enable": false,
          "bootstrap-servers": null,
          "log-retention-hours": 24,
          "num-partitions": 1
        },
        "lifecycle-state": "CREATING",
        "lifecycle-state-details": null,
        "name": "MyStreamPool",
        "private-endpoint-settings": {
          "nsg-ids": null,
          "private-endpoint-ip": null,
          "subnet-id": null
        },
        "time-created": "2020-11-02T23:01:59.429000+00:00"
      },
      "etag": "\"b0066564-4bf4-4e27-9255-9055e69a7808-03668273-b0d5-4b8b-9370-74522c29eb56\""
    }
    Consejo

    Proporcione una entrada para --custom-encryption-key-details, --private-endpoint-details y --kafka-settings como JSON con formato válido. Consulte Transferencia de entrada compleja y Uso de un archivo JSON para entrada compleja para obtener más información sobre el formato JSON.

    Para obtener una lista completa de parámetros y valores para los comandos de la CLI, consulte la referencia de comandos de la CLI.

  • Utilice la operación de API CreateStreamPool para crear un pool de flujos.

Uso de los SDK de OCI

Para crear un pool de flujos, utilice el método createStreamPool de StreamAdminClient.

Consulte la Guía para desarrolladores de Streaming para obtener ejemplos detallados de SDK.

Uso de Resource Manager y Terraform

Utilice el recurso oci_streaming_stream_pool para crear un pool de flujos con una configuración de compatibilidad con Kafka y punto final privado opcional. La configuración del punto final privado necesita una VCN, una subred y un grupo de seguridad de red. En este ejemplo, la configuración de Terraform también crea esos recursos.

Por ejemplo:

resource "oci_streaming_stream_pool" "test_stream_pool" {
  #Required
  compartment_id = var.compartment_ocid
  name           = "<stream_pool_name>"

  #Optional
  private_endpoint_settings {
    nsg_ids             = [oci_core_network_security_group.test_nsg.id]
    private_endpoint_ip = "10.0.0.5"
    subnet_id           = oci_core_subnet.test_subnet.id
  }

  kafka_settings {
    #Optional
    auto_create_topics_enable = true
    log_retention_hours       = 24
    num_partitions            = 1
  }
}

resource "oci_core_vcn" "test_vcn" {
  cidr_block     = "10.0.0.0/16"
  compartment_id = var.compartment_ocid
  display_name   = "testvcn"
  dns_label      = "dnslabel"
}

resource "oci_core_subnet" "test_subnet" {
  cidr_block     = "10.0.0.0/24"
  compartment_id = var.compartment_ocid
  vcn_id         = oci_core_vcn.test_vcn.id
}

resource "oci_core_network_security_group" "test_nsg" {
  compartment_id = var.compartment_ocid
  vcn_id         = oci_core_vcn.test_vcn.id
}
Acerca de Resource Manager y Terraform

Resource Manager es un servicio de Oracle Cloud Infrastructure (OCI) que le permite automatizar el proceso de aprovisionamiento de los recursos de OCI. Con el uso de Terraform, el gestor de recursos le ayuda a instalar, configurar y gestionar recursos con el modelo "infraestructura como código".

Una configuración de Terraform codifica la infraestructura en archivos de configuración declarativos. La configuración define los recursos que desea aprovisionar, las variables y las instrucciones específicas para aprovisionar los recursos

Puede utilizar Resource Manager o la CLI de Terraform con el proveedor de Terraform de OCI para ver cómo se representan los flujos y los pools de flujos en los archivos de configuración de Terraform.

Para obtener más información sobre la escritura de configuraciones para su uso con Resource Manager, consulte Configuraciones de Terraform para el gestor de recursos y Configuración de Terraform.