Kafka

La plataforma Devprime es compatible de forma nativa con Apache Kafka, una plataforma de streaming desarrollada por la Apache Software Foundation. El proyecto tiene como objetivo proporcionar una plataforma unificada, de alta capacidad y baja latencia para el procesamiento de datos en tiempo real.

Apache Kafka se puede usar en el entorno local, en la nube, docker, Kubernetes y plataformas administradas como Confluent Cloud, Azure Event Hub y otras.

Configuración de la transmisión con Kafka

El siguiente ejemplo de configuración muestra el uso de Apache Kafka definido con el alias “Stream1” y como valor predeterminado para el envío de eventos. Al habilitar el elemento “Suscribirse”, nos suscribimos a este tema y recibimos eventos en el concentrador de adaptadores de transmisión.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19

  "DevPrime_Stream": [
    {      
      "Enable": "true",
      "Alias": "Stream1",
      "Default": "true",
      "StreamType": "Kafka",
      "HostName": "Localhost",
      "User": "",
      "Password": "",
      "Port": "9092",
      "Retry": "3",
      "Fallback": "State1",
      "Subscribe": [
        {
          "Topics": "orderevents"
        }
      ]
    }
  ],

En el siguiente ejemplo, detallamos la configuración predeterminada del adaptador y la configuración específica de Kafka.

Generalidades —
Habilitar Habilitar el adaptador de flujo (verdadero/falso)
Alias Define un nombre único para identificar el servicio
Predeterminado Establece como valor predeterminado el centario de tener más de una secuencia (Verdadero/Falso)
Tipo de corriente Establece el tipo de secuencia (RabbitMQ
Nombre de host Configurar el Kafka
Usuario Configurar el usuario
Contraseña Configura la contraseña del usuario
Puerto Configurar el puerto
Reintentar Configurar el número de reintentos
Reserva Configura un estado para la resistencia automática en caso de error
Suscríbete Configurar Kafka

Ejemplo en el registro de la aplicación con esta configuración:

1

[INF][Stream][Type "Kafka"][Alias "Stream1"]["Enable"][Subscribe]["orderevents"]

Ejemplo de YAML con la configuración de la aplicación:

1
2
3
4

- name: devprime_stream1
    value: "alias=Stream1|||enable=true|||default=true|||streamtype=Kafka|||
    hostname=kafka.default.svc|||port=9092|||retry=3|||fallback=State1|||
    subscribe=[topics=orderevents]"
Última modificación January 10, 2024 (967dcac3)