Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy utilizando Confluent Kafka en mi proyecto donde los mensajes enviados a un tema particular necesitan ser eliminados después de un tiempo de retención. Así que configuré retention.ms para los temas individuales, pero no está funcionando (aún puedo ver los mensajes después de su tiempo de retención). He buscado la . . . 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
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