Actualmente estoy creando un servicio web REST que necesita comunicarse con Kafka en un patrón de solicitud/respuesta. (Sé que Kafka no está realmente diseñado para eso).
Los pasos 1 a 3 parecen bastante fáciles, pero estoy luchando con el paso 4.
Mi idea era propagar una ID en cada mensaje para poder recuperar la respuesta correspondiente a la solicitud.
Sin embargo, tengo dificultades para descubrir cómo configurar el oyente en el servicio web REST. ¿Cómo puede el oyente devolver el mensaje al controlador?
creo que es mejor simplemente crear un tema para cada usuario, luego el usuario puede enviar un mensaje a otro servicio, dicho mensaje es como:
{ user:"myUserName" data:"data of message" }entonces el servicio solo necesita pasar al tema "usuario.miNombreDeUsuario" Luego, desde el cliente web solo necesita estar suscrito a "usuario.miNombreDeUsuario" (con una configuración de grupo de consumidores, esto solo para leer los mensajes más nuevos)...
creo que la mejor manera es simplemente implementar websocket y luego empujar/leer de esa manera;)
Adiós y buen día.