Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Supongamos que hay un sistema Kafka con 1 partición y 2 consumidores (el segundo consumidor está inactivo). Supongamos que el primer consumidor consume un mensaje, lo envía a 3 servicios para su procesamiento y de repente se queda atascado en uno de ellos y supera el tiempo de espera de . . . Read more
Se considera que hay 4 consumidores (A, B, C, D). C se cierra llamando a close (). Idealmente, las particiones asignadas a A, B y D deberían ser revocadas antes de asignar cualquier partición nueva, pero A está siendo revocada y recibiendo nuevas particiones, y luego B está siendo revocada. . . . Read more
¿Existen API o atributos que se puedan utilizar o comparar para determinar si se han consumido todos los mensajes en una partición de un tema? Estamos trabajando en una prueba que utilizará otro consumidor del mismo grupo de consumidores para comprobar si la partición del tema aún tiene algún mensaje . . . Read more
Tengo 1 tema de kafka con solo 1 partición. En cualquier momento, puede haber varios clientes de kafka. Todos los clientes están suscritos usando el mismo grupo de consumo. Por lo tanto, en cualquier momento dado, solo 1 cliente recibiría mensajes. Digamos que desde t0 hasta t10, el consumidor1 estaba . . . Read more
Estoy construyendo una cola de mensajes no entregados. Lo que estoy interesado en implementar es la capacidad de reenviar un mensaje en su totalidad a otra cola (cuando haya un error, por ejemplo). En otras palabras, estoy interesado en preservar los metadatos del mensaje, así como su contenido. Aquí hay . . . Read more