Kafka pub/sub
Ya existe una etiqueta con el nombre de rama proporcionado. Muchos comandos Git aceptan tanto nombres de etiqueta como de rama, por lo que crear esta rama puede causar un comportamiento inesperado. ¿Estás seguro de que quieres crear esta rama?
Bienvenido a la API Pub/Sub Pub/Sub API proporciona una interfaz única para publicar y suscribirse a eventos de plataforma, incluyendo eventos de monitorización de eventos en tiempo real, y eventos de captura de datos de cambios. Basada en gRPC y HTTP/2, la API Pub/Sub permite la entrega eficiente de mensajes binarios de eventos en el formato Apache Avro.
¿Qué es la API pub-sub?
La API Pub/Sub proporciona una interfaz única para publicar y suscribirse a eventos de la plataforma, incluidos eventos de supervisión de eventos en tiempo real y eventos de captura de datos de cambios. Basada en gRPC y HTTP/2, la API Pub/Sub publica y entrega eficazmente mensajes binarios de eventos en el formato Apache Avro.
¿Cuál es la diferencia entre Kafka y Pubsub?
Pub/Sub es un servicio gestionado, por lo que se amplía y reduce en función de la demanda, mientras que las configuraciones de clúster de Kafka suelen ser autogestionadas y, por tanto, estáticas.
Patrón publicar-suscribir
Como una de las soluciones CRM más utilizadas del mercado, Salesforce desempeña un papel central en los procesos empresariales más críticos para muchas empresas. Para automatizar y optimizar completamente estos procesos empresariales, las empresas necesitan integrar Salesforce CRM con otras aplicaciones de su organización.
Las notificaciones push de temas son eventos enviados por Salesforce cuando cambia un registro. Se basan en una consulta SOQL que define cómo se producirá el evento. Se puede realizar un seguimiento de los registros cuando se crean, actualizan, eliminan o anulan.
Los eventos de captura de datos de cambios se activan cuando cambia un registro en Salesforce. Sólo tiene que configurar qué objeto desea que reciba notificaciones. Se puede realizar un seguimiento de los registros cuando se crean, actualizan, eliminan o anulan.
Además, Salesforce dispone de una función de eventos en tiempo real para ayudar a supervisar y detectar eventos estándar en Salesforce casi en tiempo real. Esto incluiría datos de eventos con fines de auditoría o elaboración de informes.
Con la nueva API Pub/Sub, todas estas funciones se consolidan en una API completa. La API Pub/Sub permite a los usuarios publicar eventos, suscribirse a eventos, solicitar esquemas y solicitar información de temas, todo dentro de una API. Elimina la necesidad de crear un cliente personalizado de CometD Streaming API.
API de la nube de Google
Las arquitecturas basadas en eventos se han convertido en un patrón de diseño muy popular en medio de la creciente demanda de resistencia y escalabilidad. El enfoque tradicional para la comunicación entre servicios ha sido el uso de API REST, pero esto introduce efectos secundarios no deseados. El cliente debe esperar a que el servidor devuelva una respuesta o se agote el tiempo de espera. Esto vincula estrechamente los servicios distribuidos, ya que el cliente debe conocer el servidor que procesará su solicitud. No hay conmutación por error; un servicio que se caiga perderá todas las peticiones entrantes, y el enfoque de utilizar un backoff exponencial para reenviar la petición es caro. Una arquitectura basada en eventos utiliza un sistema de mensajería en el que los productores envían eventos sin tener en cuenta a los consumidores. El resultado es un sistema desacoplado en el que varios servicios consumidores pueden leer un solo mensaje, y un consumidor que se caiga puede recibir los mensajes perdidos una vez que vuelva a funcionar.
El rendimiento se medirá en función de dos parámetros: 1) rendimiento y 2) retraso del consumidor. El rendimiento es el volumen de mensajes publicados por segundo, y el retraso del consumidor es el tiempo transcurrido entre la producción y el consumo de un mensaje. El retraso del consumidor también puede medirse por la distancia que separa al consumidor del productor en términos de número de mensajes en un instante de tiempo. Esto dará una idea de la carga que el marco es capaz de manejar, y la rapidez con la que entrega los mensajes a los consumidores.
Api pub/sub de Salesforce
Estas aplicaciones de ejemplo comparten un patrón común: al cargarse la aplicación, ésta obtiene una instantánea completa de su estado y utiliza una conexión persistente a través de PubSub para recibir actualizaciones de este estado. Las actualizaciones actúan como «diffs» del estado inicial.
Los clientes establecen una conexión WebSocket con nuestro servidor, escuchan los temas que les interesan y reciben mensajes sobre esos temas en tiempo real. Cada comando o mensaje enviado entre el cliente y el servidor es una cadena JSON encapsulada en una trama WebSocket.
Para evitar que el servidor cierre la conexión, los clientes deben enviar un comando PING al menos una vez cada 5 minutos. Si un cliente no recibe un mensaje PONG en los 10 segundos siguientes a la emisión de un comando PING, debe volver a conectarse al servidor. Para más información, consulte la sección Gestión de fallos de conexión.
Los clientes pueden recibir un mensaje RECONNECT en cualquier momento. Esto indica que el servidor está a punto de reiniciarse (normalmente por mantenimiento) y desconectará al cliente en 30 segundos. Durante este tiempo, recomendamos que los clientes se vuelvan a conectar al servidor; de lo contrario, el cliente será desconectado a la fuerza.
