Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Esta es la clase base del consumidor que estoy utilizando para crear nuevos consumidores. Funciona bien para el consumidor con “enable.auto.commit=True”. Pero cuando creo un consumidor con “enable.auto.commit=False” y ocurre alguna de las excepciones (KeyDeserializationError, ValueDeserializationError), entonces necesito confirmar manualmente ese mensaje en el bloque except. Como esta clase base . . . Read more
Actualmente estoy diseñando una aplicación que tendrá cientos de temas compactados de registro. Cada tema está relacionado con un grupo de conmutación por error y debería tener un conjunto dinámico (por ejemplo, que se pueda cambiar a pedido) de productores y consumidores. Por ejemplo, supongamos que tengo 3 instancias de . . . Read more
Mi problema es que tengo un marco de trabajo “dinámico” para Kafka y la creación de nuevos consumidores de Kafka ocurre sobre la marcha cuando el usuario solicita un nuevo tema. El problema es que sé que he terminado cuando el consumidor no devuelve un nuevo valor en X segundos. . . . Read more
Kafka admite la adición dinámica de nuevas particiones a un tema. Supongamos que inicialmente tengo un tema T con dos particiones P0, P1 y un espacio de claves de tres claves K0, K1, K2. Supongamos además que estoy usando algún tipo de particionador de hash módulo 2 (número de particiones) . . . Read more
¡Buen día! Me estoy registrando como consumidor de masstransit de esta manera: var provider = services.BuildServiceProvider(); cfg.ReceiveEndpoint(RabbitMqOptions.StatusChangeQueueName, e => { e.Consumer(() => new ConsumerProcessingStatusChange(provider)); }); y quiero que mi consumidor publique en otro intercambio. ¿Hay alguna forma de obtener IBus desde el proveedor de servicios en el constructor del consumidor? . . . Read more